Top Inners Fields Constructors Methods

io.reactivex.rxjava3.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.rxjava3.core.Flowable
io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream
io.reactivex.rxjava3.internal.operators.flowable.FlowableBufferTimed

Imports

java.util.*, java.util.concurrent.TimeUnit, java.util.concurrent.atomic.AtomicReference, org.reactivestreams.*, io.reactivex.rxjava3.core.*, .Scheduler.Worker, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.Supplier, io.reactivex.rxjava3.internal.disposables.DisposableHelper, io.reactivex.rxjava3.internal.queue.MpscLinkedQueue, io.reactivex.rxjava3.internal.subscribers.QueueDrainSubscriber, io.reactivex.rxjava3.internal.subscriptions.*, io.reactivex.rxjava3.internal.util.QueueDrainHelper, io.reactivex.rxjava3.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 Supplier<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.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream:: source

Constructor Summary

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

Method Summary

Modifier and Type	Method and Description
protected void	subscribeActual(Subscriber<? super U> s)

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