Class ObservableSampleWithObservable.SampleMainEmitLast<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.SampleMainEmitLast<T>
- All Implemented Interfaces:
Observer<T>
,Disposable
,Serializable
- Enclosing class:
ObservableSampleWithObservable<T>
static final class ObservableSampleWithObservable.SampleMainEmitLast<T>
extends ObservableSampleWithObservable.SampleMainObserver<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.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:
-
wip
-
done
volatile boolean done
-
-
Constructor Details
-
SampleMainEmitLast
SampleMainEmitLast(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>
-