Top Inners Fields Constructors Methods

io.reactivex.internal.operators.flowable

public final Class FlowableBufferTimed<T, U extends java.util.Collection<? super T>>

Class Inheritance

extends AbstractFlowableWithUpstream<T, U extends Collection<? super T>>

java.lang.Object
io.reactivex.Flowable
io.reactivex.internal.operators.flowable.AbstractFlowableWithUpstream
io.reactivex.internal.operators.flowable.FlowableBufferTimed

Imports

java.util.*, java.util.concurrent.*, java.util.concurrent.atomic.AtomicReference, org.reactivestreams.*, io.reactivex.*, .Scheduler.Worker, io.reactivex.disposables.Disposable, io.reactivex.exceptions.Exceptions, io.reactivex.internal.disposables.DisposableHelper, io.reactivex.internal.functions.ObjectHelper, io.reactivex.internal.queue.MpscLinkedQueue, io.reactivex.internal.subscribers.QueueDrainSubscriber, io.reactivex.internal.subscriptions.*, io.reactivex.internal.util.QueueDrainHelper, io.reactivex.subscribers.SerializedSubscriber

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FlowableBufferTimed.BufferExactBoundedSubscriber<T, U extends Collection<? super T>>
pack-priv static class	FlowableBufferTimed.BufferExactUnboundedSubscriber<T, U extends Collection<? super T>>
pack-priv static class	FlowableBufferTimed.BufferSkipBoundedSubscriber<T, U extends Collection<? super T>>

Field Summary

Modifier and Type	Field and Description
pack-priv final Callable<U>	bufferSupplier
pack-priv final int	maxSize
pack-priv final boolean	restartTimerOnMaxSize
pack-priv final Scheduler	scheduler
pack-priv final long	timeskip
pack-priv final long	timespan
pack-priv final TimeUnit	unit

Inherited from io.reactivex.internal.operators.flowable.AbstractFlowableWithUpstream:: source

Constructor Summary

Access	Constructor and Description
public	FlowableBufferTimed(Flowable<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, Callable<U> bufferSupplier, int maxSize, boolean restartTimerOnMaxSize)

Method Summary

Modifier and Type	Method and Description
protected void	subscribeActual(Subscriber<? super U> the incoming Subscriber, never null s) Implements abstract io.reactivex.Flowable.subscribeActual. Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming `Subscriber`s.

Inherited from io.reactivex.internal.operators.flowable.AbstractFlowableWithUpstream:: source