hu.akarnokd.reactive4java.reactive

Class Buffer.WithSizeOrTime<T>

java.lang.Object

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

Type Parameters:

T - the type of the values

All Implemented Interfaces:

Observable<java.util.List<T>>

Enclosing class:

Buffer

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

Buffer the Ts of the source until the buffer reaches its capacity or the current time unit runs out. Might result in empty list of Ts and might complete early when the source finishes before the buffer runs out.

Constructor Summary

Constructors

Constructor and Description
WithSizeOrTime(Observable<? extends T> source, int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler pool) 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

Constructor Detail

WithSizeOrTime

public WithSizeOrTime(Observable<? extends T> source,
                      int bufferSize,
                      long time,
                      java.util.concurrent.TimeUnit unit,
                      Scheduler pool)

Constructor.

Parameters:

source - the source observable

bufferSize - the allowed buffer size

time - the time value to wait between buffer fills

unit - the time unit

pool - the pool where to schedule the buffer splits

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