Package io.reactivex.rxjava3.internal.operators.flowable

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

Fields

Modifier and Type	Field	Description
(package private) boolean	done
private static final long	serialVersionUID
(package private) final AtomicInteger	wip

Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableSamplePublisher.SamplePublisherSubscriber

downstream, other, requested, sampler, upstream

Constructor Summary

Constructors

Constructor	Description
SampleMainEmitLast(org.reactivestreams.Subscriber<? super T> actual, org.reactivestreams.Publisher<?> other)

Method Summary

Modifier and Type	Method	Description
(package private) void	completion()
(package private) void	run()

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

wip

final AtomicInteger 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 class FlowableSamplePublisher.SamplePublisherSubscriber<T>

run

void run()

Specified by:

run in class FlowableSamplePublisher.SamplePublisherSubscriber<T>