public final class OperatorBufferTimed<T,U extends java.util.Collection<? super T>> extends java.lang.Object implements Observable.Operator<U,T>
| Constructor and Description |
|---|
OperatorBufferTimed(long timespan,
long timeskip,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
Supplier<U> bufferSupplier,
int maxSize,
boolean restartTimerOnMaxSize) |
| Modifier and Type | Method and Description |
|---|---|
org.reactivestreams.Subscriber<? super T> |
apply(org.reactivestreams.Subscriber<? super U> t) |