hu.akarnokd.reactive4java.reactive

Class Buffer.WithSizeSkip<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Buffer.WithSizeSkip<T>

Type Parameters:

T - the type of the elements

All Implemented Interfaces:

Observable<java.util.List<T>>

Enclosing class:

Buffer

public static final class Buffer.WithSizeSkip<T>
extends java.lang.Object
implements Observable<java.util.List<T>>

Project the source sequence to potentially overlapping buffers whose start is determined by skip and lengths by size.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	skip The skip count.

Constructor Summary

Constructors

Constructor and Description
WithSizeSkip(Observable<? extends T> source, int bufferSize, int skip) Constructor.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super java.util.List<T>> observer) Registers an observer for the notification of Ts.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

skip

protected final int skip

The skip count.

Constructor Detail

WithSizeSkip

public WithSizeSkip(Observable<? extends T> source,
                    int bufferSize,
                    int skip)

Constructor.

Parameters:

source - the source observable

bufferSize - the target buffer size

skip - the number of items to skip between buffers

Method Detail

register

@Nonnull
public java.io.Closeable register(@Nonnull
                                            Observer<? super java.util.List<T>> observer)

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<java.util.List<T>>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider