Class ObservableStageObserver<T>

java.lang.Object
java.util.concurrent.CompletableFuture<T>
io.reactivex.rxjava3.internal.jdk8.ObservableStageObserver<T>
Type Parameters:
T - the element type
All Implemented Interfaces:
Observer<T>, CompletionStage<T>, Future<T>
Direct Known Subclasses:
ObservableFirstStageObserver, ObservableLastStageObserver, ObservableSingleStageObserver

abstract class ObservableStageObserver<T> extends CompletableFuture<T> implements Observer<T>
Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.
Since:
3.0.0