Class ObservableSampleTimed.SampleTimedNoLast<T>
java.lang.Object
java.util.concurrent.atomic.AtomicReference<T>
io.reactivex.rxjava3.internal.operators.observable.ObservableSampleTimed.SampleTimedObserver<T>
io.reactivex.rxjava3.internal.operators.observable.ObservableSampleTimed.SampleTimedNoLast<T>
- All Implemented Interfaces:
Observer<T>
,Disposable
,Serializable
,Runnable
- Enclosing class:
ObservableSampleTimed<T>
static final class ObservableSampleTimed.SampleTimedNoLast<T>
extends ObservableSampleTimed.SampleTimedObserver<T>
-
Field Summary
FieldsFields inherited from class io.reactivex.rxjava3.internal.operators.observable.ObservableSampleTimed.SampleTimedObserver
downstream, onDropped, period, scheduler, timer, unit, upstream
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.operators.observable.ObservableSampleTimed.SampleTimedObserver
cancelTimer, dispose, emit, isDisposed, onComplete, onError, onNext, onSubscribe
Methods inherited from class java.util.concurrent.atomic.AtomicReference
accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
-
Constructor Details
-
SampleTimedNoLast
-
-
Method Details
-
complete
void complete()- Specified by:
complete
in classObservableSampleTimed.SampleTimedObserver<T>
-
run
public void run()
-