Class FutureObserver<T>

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

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