Class BlockingLastSubscriber<T>
java.lang.Object
java.util.concurrent.CountDownLatch
io.reactivex.rxjava3.internal.subscribers.BlockingBaseSubscriber<T>
io.reactivex.rxjava3.internal.subscribers.BlockingLastSubscriber<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
FlowableSubscriber<T>
,org.reactivestreams.Subscriber<T>
Blocks until the upstream signals its last value or completes.
-
Field Summary
Fields inherited from class io.reactivex.rxjava3.internal.subscribers.BlockingBaseSubscriber
cancelled, error, upstream, value
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.subscribers.BlockingBaseSubscriber
blockingGet, onComplete, onSubscribe
-
Constructor Details
-
BlockingLastSubscriber
public BlockingLastSubscriber()
-
-
Method Details
-
onNext
-
onError
-