T - the type of the valuespublic static final class Buffer.WithSizeOrTime<T> extends java.lang.Object implements Observable<java.util.List<T>>
| Constructor and Description |
|---|
WithSizeOrTime(Observable<? extends T> source,
int bufferSize,
long time,
java.util.concurrent.TimeUnit unit,
Scheduler pool)
Constructor.
|
| 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.
|
public WithSizeOrTime(Observable<? extends T> source, int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler pool)
source - the source observablebufferSize - the allowed buffer sizetime - the time value to wait between buffer fillsunit - the time unitpool - the pool where to schedule the buffer splits@Nonnull
public java.io.Closeable register(@Nonnull
Observer<? super java.util.List<T>> observer)
Observableregister in interface Observable<java.util.List<T>>observer - the observer of Ts or any supertype of it