Top Inners Fields Constructors Methods

io.reactivex.rxjava3.internal.operators.flowable

public final Class FlowableWindowTimed<T>

Class Inheritance

extends AbstractFlowableWithUpstream<T, Flowable<T>>

java.lang.Object
io.reactivex.rxjava3.core.Flowable
io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream
io.reactivex.rxjava3.internal.operators.flowable.FlowableWindowTimed

Imports

java.util.*, java.util.concurrent.TimeUnit, java.util.concurrent.atomic.*, org.reactivestreams.*, io.reactivex.rxjava3.core.*, .Scheduler.Worker, io.reactivex.rxjava3.exceptions.MissingBackpressureException, io.reactivex.rxjava3.internal.disposables.SequentialDisposable, io.reactivex.rxjava3.internal.queue.MpscLinkedQueue, io.reactivex.rxjava3.internal.subscriptions.SubscriptionHelper, io.reactivex.rxjava3.internal.util.BackpressureHelper, io.reactivex.rxjava3.operators.SimplePlainQueue, io.reactivex.rxjava3.processors.UnicastProcessor

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv abstract static class	FlowableWindowTimed.AbstractWindowSubscriber<T>
pack-priv static class	FlowableWindowTimed.WindowExactBoundedSubscriber<T>
pack-priv static class	FlowableWindowTimed.WindowExactUnboundedSubscriber<T>
pack-priv static class	FlowableWindowTimed.WindowSkipSubscriber<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final int	bufferSize
pack-priv final long	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	FlowableWindowTimed(Flowable<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, long maxSize, int bufferSize, boolean restartTimerOnMaxSize)

Method Summary

Modifier and Type	Method and Description
pack-priv static MissingBackpressureException	missingBackpressureMessage(long index)
protected void	subscribeActual(Subscriber<? super Flowable<T>> downstream)

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