Class ObservableSampleWithObservable.SampleMainNoLast<T>
java.lang.Object
java.util.concurrent.atomic.AtomicReference<T>
io.reactivex.rxjava3.internal.operators.observable.ObservableSampleWithObservable.SampleMainObserver<T>
io.reactivex.rxjava3.internal.operators.observable.ObservableSampleWithObservable.SampleMainNoLast<T>
- All Implemented Interfaces:
Observer<T>
,Disposable
,Serializable
- Enclosing class:
ObservableSampleWithObservable<T>
static final class ObservableSampleWithObservable.SampleMainNoLast<T>
extends ObservableSampleWithObservable.SampleMainObserver<T>
-
Field Summary
FieldsFields inherited from class io.reactivex.rxjava3.internal.operators.observable.ObservableSampleWithObservable.SampleMainObserver
downstream, other, sampler, upstream
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.operators.observable.ObservableSampleWithObservable.SampleMainObserver
complete, dispose, emit, error, isDisposed, onComplete, onError, onNext, onSubscribe, 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(Observer<? super T> actual, ObservableSource<?> other)
-
-
Method Details
-
completion
void completion()- Specified by:
completion
in classObservableSampleWithObservable.SampleMainObserver<T>
-
run
void run()- Specified by:
run
in classObservableSampleWithObservable.SampleMainObserver<T>
-