public abstract class BlockingBaseSubscriber<T> extends CountDownLatch implements FlowableSubscriber<T>
Constructor and Description |
---|
BlockingBaseSubscriber() |
Modifier and Type | Method and Description |
---|---|
T |
blockingGet()
Block until the first value arrives and return it, otherwise
return null for an empty source and rethrow any exception.
|
void |
onComplete() |
void |
onSubscribe(org.reactivestreams.Subscription s)
Implementors of this method should make sure everything that needs
to be visible in
Subscriber.onNext(Object) is established before
calling Subscription.request(long) . |
await, await, countDown, getCount, toString
public final void onSubscribe(org.reactivestreams.Subscription s)
FlowableSubscriber
Subscriber.onNext(Object)
is established before
calling Subscription.request(long)
. In practice this means
no initialization should happen after the request()
call and
additional behavior is thread safe in respect to onNext
.
onSubscribe
in interface FlowableSubscriber<T>
onSubscribe
in interface org.reactivestreams.Subscriber<T>
public final void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<T>
public final T blockingGet()
Copyright © 2018 JBoss by Red Hat. All rights reserved.