Class ObservableWindowTimed.WindowSkipObserver<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.WindowSkipObserver<T>
- All Implemented Interfaces:
Observer<T>
,Disposable
,Serializable
,Runnable
- Enclosing class:
ObservableWindowTimed<T>
static final class ObservableWindowTimed.WindowSkipObserver<T>
extends ObservableWindowTimed.AbstractWindowObserver<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
<UnicastSubject<T>> (package private) final Scheduler.Worker
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
ConstructorsConstructorDescriptionWindowSkipObserver
(Observer<? super Observable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, 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:
-
timeskip
final long timeskip -
worker
-
windows
-
WINDOW_OPEN
-
WINDOW_CLOSE
-
-
Constructor Details
-
WindowSkipObserver
WindowSkipObserver(Observer<? super Observable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, int bufferSize)
-
-
Method Details
-
createFirstWindow
void createFirstWindow()- Specified by:
createFirstWindow
in classObservableWindowTimed.AbstractWindowObserver<T>
-
cleanupResources
void cleanupResources()- Specified by:
cleanupResources
in classObservableWindowTimed.AbstractWindowObserver<T>
-
drain
void drain()- Specified by:
drain
in classObservableWindowTimed.AbstractWindowObserver<T>
-
run
public void run() -
boundary
void boundary(boolean isOpen)
-