Class ObservableWindowTimed.WindowExactUnboundedObserver<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.observable.ObservableWindowTimed.AbstractWindowObserver<T>
io.reactivex.rxjava3.internal.operators.observable.ObservableWindowTimed.WindowExactUnboundedObserver<T>
- All Implemented Interfaces:
Observer<T>
,Disposable
,Serializable
,Runnable
- Enclosing class:
ObservableWindowTimed<T>
static final class ObservableWindowTimed.WindowExactUnboundedObserver<T>
extends ObservableWindowTimed.AbstractWindowObserver<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) UnicastSubject
<T> (package private) final Runnable
Fields inherited from class io.reactivex.rxjava3.internal.operators.observable.ObservableWindowTimed.AbstractWindowObserver
bufferSize, done, downstream, downstreamCancelled, emitted, error, queue, timespan, unit, upstream, upstreamCancelled, windowCount
-
Constructor Summary
ConstructorsConstructorDescriptionWindowExactUnboundedObserver
(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize) -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.operators.observable.ObservableWindowTimed.AbstractWindowObserver
dispose, isDisposed, onComplete, onError, onNext, onSubscribe, 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
UnicastSubject<T> window -
timer
-
NEXT_WINDOW
-
windowRunnable
-
-
Constructor Details
-
WindowExactUnboundedObserver
WindowExactUnboundedObserver(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize)
-
-
Method Details
-
createFirstWindow
void createFirstWindow()- Specified by:
createFirstWindow
in classObservableWindowTimed.AbstractWindowObserver<T>
-
run
public void run() -
drain
void drain()- Specified by:
drain
in classObservableWindowTimed.AbstractWindowObserver<T>
-
cleanupResources
void cleanupResources()- Specified by:
cleanupResources
in classObservableWindowTimed.AbstractWindowObserver<T>
-