FlowableSamplePublisher.SampleMainNoLast

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

Fields

Modifier and Type

Field

Description

private static final long

serialVersionUID

Fields inherited from class FlowableSamplePublisher.SamplePublisherSubscriber
downstream, other, requested, sampler, upstream
Constructor Summary

Constructors

Constructor

Description

SampleMainNoLast(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 FlowableSamplePublisher.SamplePublisherSubscriber
cancel, complete, emit, error, onComplete, onError, onNext, onSubscribe, request, setOther

Methods inherited from class 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 Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details
- serialVersionUID
  private static final long serialVersionUID
  
  See Also:
  
  Constant Field Values
Constructor Details
- SampleMainNoLast
  
  SampleMainNoLast(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>