Class BlockingDisposableMultiObserver<T>

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

public final class BlockingDisposableMultiObserver<T> extends CountDownLatch implements MaybeObserver<T>, SingleObserver<T>, CompletableObserver, Disposable
Blocks until the upstream terminates and dispatches the outcome to the actual observer.
Since:
3.0.0