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>
public final class BlockingLastSubscriber<T> extends BlockingBaseSubscriber<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 Constructor Description BlockingLastSubscriber()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onError(java.lang.Throwable t)
void
onNext(T t)
-
Methods inherited from class io.reactivex.rxjava3.internal.subscribers.BlockingBaseSubscriber
blockingGet, onComplete, onSubscribe
-
-
-
-
Method Detail
-
onNext
public void onNext(T t)
-
onError
public void onError(java.lang.Throwable t)
-
-