Class FlowableWindowTimed.WindowExactUnboundedSubscriber<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.flowable.FlowableWindowTimed.AbstractWindowSubscriber<T>
io.reactivex.rxjava3.internal.operators.flowable.FlowableWindowTimed.WindowExactUnboundedSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,Runnable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
FlowableWindowTimed<T>
static final class FlowableWindowTimed.WindowExactUnboundedSubscriber<T>
extends FlowableWindowTimed.AbstractWindowSubscriber<T>
implements Runnable
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) static final Object
(package private) final Scheduler
private static final long
(package private) final SequentialDisposable
(package private) UnicastProcessor
<T> (package private) final Runnable
Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableWindowTimed.AbstractWindowSubscriber
bufferSize, done, downstream, downstreamCancelled, emitted, error, queue, requested, timespan, unit, upstream, upstreamCancelled, windowCount
-
Constructor Summary
ConstructorsConstructorDescriptionWindowExactUnboundedSubscriber
(org.reactivestreams.Subscriber<? super Flowable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize) -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableWindowTimed.AbstractWindowSubscriber
cancel, onComplete, onError, onNext, onSubscribe, request, windowDone
Methods inherited from class java.util.concurrent.atomic.AtomicInteger
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
Methods inherited from class java.lang.Number
byteValue, shortValue
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
scheduler
-
window
UnicastProcessor<T> window -
timer
-
NEXT_WINDOW
-
windowRunnable
-
-
Constructor Details
-
WindowExactUnboundedSubscriber
-
-
Method Details
-
createFirstWindow
void createFirstWindow()- Specified by:
createFirstWindow
in classFlowableWindowTimed.AbstractWindowSubscriber<T>
-
run
public void run() -
drain
void drain()- Specified by:
drain
in classFlowableWindowTimed.AbstractWindowSubscriber<T>
-
cleanupResources
void cleanupResources()- Specified by:
cleanupResources
in classFlowableWindowTimed.AbstractWindowSubscriber<T>
-