Class FlowableSamplePublisher.SampleMainEmitLast<T>
java.lang.Object
java.util.concurrent.atomic.AtomicReference<T>
io.reactivex.rxjava3.internal.operators.flowable.FlowableSamplePublisher.SamplePublisherSubscriber<T>
io.reactivex.rxjava3.internal.operators.flowable.FlowableSamplePublisher.SampleMainEmitLast<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
FlowableSamplePublisher<T>
static final class FlowableSamplePublisher.SampleMainEmitLast<T>
extends FlowableSamplePublisher.SamplePublisherSubscriber<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
private static final long
(package private) final AtomicInteger
Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableSamplePublisher.SamplePublisherSubscriber
downstream, other, requested, sampler, upstream
-
Constructor Summary
ConstructorsConstructorDescriptionSampleMainEmitLast
(org.reactivestreams.Subscriber<? super T> actual, org.reactivestreams.Publisher<?> other) -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableSamplePublisher.SamplePublisherSubscriber
cancel, complete, emit, error, onComplete, onError, onNext, onSubscribe, request, setOther
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
-
done
volatile boolean done
-
-
Constructor Details
-
SampleMainEmitLast
SampleMainEmitLast(org.reactivestreams.Subscriber<? super T> actual, org.reactivestreams.Publisher<?> other)
-
-
Method Details
-
completion
void completion()- Specified by:
completion
in classFlowableSamplePublisher.SamplePublisherSubscriber<T>
-
run
void run()- Specified by:
run
in classFlowableSamplePublisher.SamplePublisherSubscriber<T>
-