Class CompletionStageConsumer<T>

java.lang.Object
java.util.concurrent.CompletableFuture<T>
io.reactivex.rxjava3.internal.jdk8.CompletionStageConsumer<T>
Type Parameters:
T - the element type
All Implemented Interfaces:
CompletableObserver, MaybeObserver<T>, SingleObserver<T>, CompletionStage<T>, Future<T>

public final class CompletionStageConsumer<T> extends CompletableFuture<T> implements MaybeObserver<T>, SingleObserver<T>, CompletableObserver
Class that extends CompletableFuture and converts multiple types of reactive consumers and their signals into completion signals.
Since:
3.0.0