Top Fields Constructors Methods
io.reactivex.internal.subscribers

public abstract Class BlockingBaseSubscriber<T>

extends CountDownLatch
implements FlowableSubscriber<T>
Class Inheritance
All Implemented Interfaces
io.reactivex.FlowableSubscriber, org.reactivestreams.Subscriber
Known Direct Subclasses
io.reactivex.internal.subscribers.BlockingFirstSubscriber, io.reactivex.internal.subscribers.BlockingLastSubscriber
Imports
java.util.concurrent.CountDownLatch, org.reactivestreams.Subscription, io.reactivex.FlowableSubscriber, io.reactivex.internal.subscriptions.SubscriptionHelper, io.reactivex.internal.util.*

Field Summary

Modifier and TypeField and Description
pack-priv volatile boolean
cancelled

pack-priv Throwable
error

pack-priv Subscription
upstream

pack-priv T
value

Constructor Summary

AccessConstructor and Description
public
BlockingBaseSubscriber()

Method Summary

Modifier and TypeMethod and Description
public final T

Returns:

the first value or null if the source is empty
blockingGet()

Block until the first value arrives and return it, otherwise return null for an empty source and rethrow any exception.

public final void
onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Successful terminal state.
public final void
onSubscribe(Subscription
the Subscription that allows requesting data via Subscription#request(long)
s)

Implements io.reactivex.FlowableSubscriber.onSubscribe.

Implementors of this method should make sure everything that needs to be visible in onNext(Object) is established before calling Subscription#request(long).
Inherited from java.util.concurrent.CountDownLatch:
awaitawaitcountDowngetCounttoString

Field Detail

cancelledback to summary
pack-priv volatile boolean cancelled
errorback to summary
pack-priv Throwable error
upstreamback to summary
pack-priv Subscription upstream
valueback to summary
pack-priv T value

Constructor Detail

BlockingBaseSubscriberback to summary
public BlockingBaseSubscriber()

Method Detail

blockingGetback to summary
public final T blockingGet()

Block until the first value arrives and return it, otherwise return null for an empty source and rethrow any exception.

Returns:T

the first value or null if the source is empty

onCompleteback to summary
public final void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations
@Override
onSubscribeback to summary
public final void onSubscribe(Subscription s)

Implements io.reactivex.FlowableSubscriber.onSubscribe.

Doc from io.reactivex.FlowableSubscriber.onSubscribe.

Implementors of this method should make sure everything that needs to be visible in 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. Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters
s:Subscription

Doc from org.reactivestreams.Subscriber.onSubscribe.

the Subscription that allows requesting data via Subscription#request(long)

Annotations
@Override