Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.jdk8

pack-priv abstract Class ObservableStageObserver<T>

extends CompletableFuture<T>
implements Observer<T>
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.core.Observer
Known Direct Subclasses
io.reactivex.rxjava3.internal.jdk8.ObservableFirstStageObserver, io.reactivex.rxjava3.internal.jdk8.ObservableLastStageObserver, io.reactivex.rxjava3.internal.jdk8.ObservableSingleStageObserver
Type Parameters
<T>
the element type
Imports
java.util.concurrent.CompletableFuture, java.util.concurrent.atomic.AtomicReference, io.reactivex.rxjava3.annotations.NonNull, io.reactivex.rxjava3.core.Observer, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.internal.disposables.DisposableHelper, io.reactivex.rxjava3.plugins.RxJavaPlugins
Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.
Since
3.0.0

Field Summary

Modifier and TypeField and Description
pack-priv final AtomicReference<Disposable>
upstream

pack-priv T
value

Constructor Summary

AccessConstructor and Description
pack-priv
ObservableStageObserver()

Method Summary

Modifier and TypeMethod and Description
public final boolean
cancel(boolean
this value has no effect in this implementation because interrupts are not used to control processing.
mayInterruptIfRunning)

Overrides java.util.concurrent.CompletableFuture.cancel.

Implements java.util.concurrent.Future.cancel.

If not already completed, completes this CompletableFuture with a CancellationException.
protected final void
clear()

public final boolean
complete(T
the result value
value)

Overrides java.util.concurrent.CompletableFuture.complete.

If not already completed, sets the value returned by get() and related methods to the given value.
public final boolean
completeExceptionally(Throwable
the exception
ex)

Overrides java.util.concurrent.CompletableFuture.completeExceptionally.

If not already completed, causes invocations of get() and related methods to throw the given exception.
protected final void
disposeUpstream()

public final void
onError(Throwable t)

public final void
onSubscribe(@NonNull Disposable d)

Inherited from java.util.concurrent.CompletableFuture:
acceptEitheracceptEitherAsyncacceptEitherAsyncallOfanyOfapplyToEitherapplyToEitherAsyncapplyToEitherAsynccompleteAsynccompleteAsynccompletedFuturecompletedStagecompleteOnTimeoutcopydefaultExecutordelayedExecutordelayedExecutorexceptionallyexceptionallyAsyncexceptionallyAsyncexceptionallyComposeexceptionallyComposeAsyncexceptionallyComposeAsyncexceptionNowfailedFuturefailedStagegetgetgetNowgetNumberOfDependentshandlehandleAsynchandleAsyncisCancelledisCompletedExceptionallyisDonejoinminimalCompletionStagenewIncompleteFutureobtrudeExceptionobtrudeValueorTimeoutresultNowrunAfterBothrunAfterBothAsyncrunAfterBothAsyncrunAfterEitherrunAfterEitherAsyncrunAfterEitherAsyncrunAsyncrunAsyncstatesupplyAsyncsupplyAsyncthenAcceptthenAcceptAsyncthenAcceptAsyncthenAcceptBoththenAcceptBothAsyncthenAcceptBothAsyncthenApplythenApplyAsyncthenApplyAsyncthenCombinethenCombineAsyncthenCombineAsyncthenComposethenComposeAsyncthenComposeAsyncthenRunthenRunAsyncthenRunAsynctoCompletableFuturetoStringwhenCompletewhenCompleteAsyncwhenCompleteAsync

Field Detail

upstreamback to summary
pack-priv final AtomicReference<Disposable> upstream
valueback to summary
pack-priv T value

Constructor Detail

ObservableStageObserverback to summary
pack-priv ObservableStageObserver()

Method Detail

cancelback to summary
public final boolean cancel(boolean mayInterruptIfRunning)

Overrides java.util.concurrent.CompletableFuture.cancel.

Implements java.util.concurrent.Future.cancel.

Doc from java.util.concurrent.CompletableFuture.cancel.

If not already completed, completes this CompletableFuture with a CancellationException. Dependent CompletableFutures that have not already completed will also complete exceptionally, with a CompletionException caused by this CancellationException.

Parameters
mayInterruptIfRunning:boolean

this value has no effect in this implementation because interrupts are not used to control processing.

Returns:boolean

true if this task is now cancelled

Annotations
@Override
clearback to summary
protected final void clear()
completeback to summary
public final boolean complete(T value)

Overrides java.util.concurrent.CompletableFuture.complete.

Doc from java.util.concurrent.CompletableFuture.complete.

If not already completed, sets the value returned by get() and related methods to the given value.

Parameters
value:T

the result value

Returns:boolean

true if this invocation caused this CompletableFuture to transition to a completed state, else false

Annotations
@Override
completeExceptionallyback to summary
public final boolean completeExceptionally(Throwable ex)

Overrides java.util.concurrent.CompletableFuture.completeExceptionally.

Doc from java.util.concurrent.CompletableFuture.completeExceptionally.

If not already completed, causes invocations of get() and related methods to throw the given exception.

Parameters
ex:Throwable

the exception

Returns:boolean

true if this invocation caused this CompletableFuture to transition to a completed state, else false

Annotations
@Override
disposeUpstreamback to summary
protected final void disposeUpstream()
onErrorback to summary
public final void onError(Throwable t)
Annotations
@Override
onSubscribeback to summary
public final void onSubscribe(@NonNull Disposable d)
Annotations
@Override