Class FlowableSampleTimed.SampleTimedEmitLast<T>
java.lang.Object
java.util.concurrent.atomic.AtomicReference<T>
io.reactivex.rxjava3.internal.operators.flowable.FlowableSampleTimed.SampleTimedSubscriber<T>
io.reactivex.rxjava3.internal.operators.flowable.FlowableSampleTimed.SampleTimedEmitLast<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,Runnable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
FlowableSampleTimed<T>
static final class FlowableSampleTimed.SampleTimedEmitLast<T>
extends FlowableSampleTimed.SampleTimedSubscriber<T>
-
Field Summary
FieldsFields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableSampleTimed.SampleTimedSubscriber
downstream, onDropped, period, requested, scheduler, timer, unit, upstream
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableSampleTimed.SampleTimedSubscriber
cancel, cancelTimer, emit, onComplete, onError, onNext, onSubscribe, request
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:
-
wip
-
-
Constructor Details
-
SampleTimedEmitLast
-
-
Method Details
-
complete
void complete()- Specified by:
complete
in classFlowableSampleTimed.SampleTimedSubscriber<T>
-
run
public void run()
-