Class FutureMultiObserver<T>

java.lang.Object
java.util.concurrent.CountDownLatch
io.reactivex.rxjava3.internal.observers.FutureMultiObserver<T>
Type Parameters:
T - the value type
All Implemented Interfaces:
CompletableObserver, MaybeObserver<T>, SingleObserver<T>, Disposable, Future<T>

public final class FutureMultiObserver<T> extends CountDownLatch implements MaybeObserver<T>, SingleObserver<T>, CompletableObserver, Future<T>, Disposable
An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.