Class FlowableWindowTimed.WindowSkipSubscriber<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.WindowSkipSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,Runnable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
FlowableWindowTimed<T>
static final class FlowableWindowTimed.WindowSkipSubscriber<T>
extends FlowableWindowTimed.AbstractWindowSubscriber<T>
implements Runnable
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final long
(package private) final long
(package private) static final Object
(package private) static final Object
(package private) final List
<UnicastProcessor<T>> (package private) final Scheduler.Worker
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
ConstructorsConstructorDescriptionWindowSkipSubscriber
(org.reactivestreams.Subscriber<? super Flowable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, 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:
-
timeskip
final long timeskip -
worker
-
windows
-
WINDOW_OPEN
-
WINDOW_CLOSE
-
-
Constructor Details
-
WindowSkipSubscriber
WindowSkipSubscriber(org.reactivestreams.Subscriber<? super Flowable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, int bufferSize)
-
-
Method Details
-
createFirstWindow
void createFirstWindow()- Specified by:
createFirstWindow
in classFlowableWindowTimed.AbstractWindowSubscriber<T>
-
cleanupResources
void cleanupResources()- Specified by:
cleanupResources
in classFlowableWindowTimed.AbstractWindowSubscriber<T>
-
drain
void drain()- Specified by:
drain
in classFlowableWindowTimed.AbstractWindowSubscriber<T>
-
run
public void run() -
boundary
void boundary(boolean isOpen)
-