Class FlowableSamplePublisher.SampleMainNoLast<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.SampleMainNoLast<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
FlowableSamplePublisher<T>
static final class FlowableSamplePublisher.SampleMainNoLast<T>
extends FlowableSamplePublisher.SamplePublisherSubscriber<T>
-
Field Summary
FieldsFields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableSamplePublisher.SamplePublisherSubscriber
downstream, other, requested, sampler, upstream
-
Constructor Summary
ConstructorsConstructorDescriptionSampleMainNoLast
(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:
-
-
Constructor Details
-
SampleMainNoLast
SampleMainNoLast(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>
-