Top Inners Fields Constructors Methods
io.reactivex.internal.operators.flowable

public final Class FlowableWindowTimed<T>

extends AbstractFlowableWithUpstream<T, Flowable<T>>
Class Inheritance
Imports
java.util.*, java.util.concurrent.TimeUnit, org.reactivestreams.*, io.reactivex.*, .Scheduler.Worker, io.reactivex.disposables.Disposable, io.reactivex.exceptions.MissingBackpressureException, io.reactivex.internal.disposables.*, io.reactivex.internal.fuseable.SimplePlainQueue, io.reactivex.internal.queue.MpscLinkedQueue, io.reactivex.internal.subscribers.QueueDrainSubscriber, io.reactivex.internal.subscriptions.SubscriptionHelper, io.reactivex.internal.util.NotificationLite, io.reactivex.processors.UnicastProcessor, io.reactivex.subscribers.SerializedSubscriber

Nested and Inner Type Summary

Modifier and TypeClass and Description
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 TypeField 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.internal.operators.flowable.AbstractFlowableWithUpstream:
source

Constructor Summary

AccessConstructor 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 TypeMethod and Description
protected void
subscribeActual(Subscriber<? super Flowable<T>>
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 Subscribers.
Inherited from io.reactivex.internal.operators.flowable.AbstractFlowableWithUpstream:
source