Class ObservableFromCompletionStage.CompletionStageHandler<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable<T>
io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable<T>
io.reactivex.rxjava3.internal.jdk8.ObservableFromCompletionStage.CompletionStageHandler<T>
- All Implemented Interfaces:
Disposable
,QueueDisposable<T>
,QueueFuseable<T>
,SimpleQueue<T>
,Serializable
,BiConsumer<T,
Throwable>
- Enclosing class:
ObservableFromCompletionStage<T>
static final class ObservableFromCompletionStage.CompletionStageHandler<T>
extends DeferredScalarDisposable<T>
implements BiConsumer<T,Throwable>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final long
(package private) final ObservableFromCompletionStage.BiConsumerAtomicReference
<T> Fields inherited from class io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable
downstream, value
-
Constructor Summary
ConstructorsConstructorDescriptionCompletionStageHandler
(Observer<? super T> downstream, ObservableFromCompletionStage.BiConsumerAtomicReference<T> whenReference) -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable
clear, complete, complete, error, isDisposed, isEmpty, poll, requestFusion, tryDispose
Methods inherited from class io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable
offer, offer
Methods inherited from class java.util.concurrent.atomic.AtomicInteger
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
Methods inherited from class java.lang.Number
byteValue, shortValue
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface java.util.function.BiConsumer
andThen
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
whenReference
-
-
Constructor Details
-
CompletionStageHandler
CompletionStageHandler(Observer<? super T> downstream, ObservableFromCompletionStage.BiConsumerAtomicReference<T> whenReference)
-
-
Method Details
-
accept
- Specified by:
accept
in interfaceBiConsumer<T,
Throwable>
-
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
- Overrides:
dispose
in classDeferredScalarDisposable<T>
-