T - the value typepublic final class SerializedSubscriber<T> extends Object implements FlowableSubscriber<T>, Subscription
Note that onSubscribe(Subscription) is not serialized in respect of the other methods so
make sure the onSubscribe is called with a non-null Subscription
before any of the other methods are called.
The implementation assumes that the actual Subscriber's methods don't throw.
| Constructor and Description |
|---|
SerializedSubscriber (Subscriber<? super T> downstream)
Construct a SerializedSubscriber by wrapping the given actual Subscriber.
|
SerializedSubscriber (Subscriber<? super T> actual,
boolean delayError)
Construct a SerializedSubscriber by wrapping the given actual Observer and
optionally delaying the errors till all regular values have been emitted
from the internal buffer.
|
| Modifier and Type | Method and Description |
|---|---|
void |
cancel () |
void |
onComplete () |
void |
onError (Throwable t) |
void |
onNext (T t) |
void |
onSubscribe (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). |
void |
request (long n) |
public SerializedSubscriber(Subscriber<? super T> downstream)
downstream - the actual Subscriber, not null (not verified)public SerializedSubscriber(Subscriber<? super T> actual, boolean delayError)
actual - the actual Subscriber, not null (not verified)delayError - if true, errors are emitted after regular values have been emittedpublic void onSubscribe(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 Subscriber<T>public void onNext(T t)
onNext in interface Subscriber<T>public void onError(Throwable t)
onError in interface Subscriber<T>public void onComplete()
onComplete in interface Subscriber<T>public void request(long n)
request in interface Subscription public void cancel()
cancel in interface Subscription