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