T - the value typepublic final class SerializedSubscriber<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>
Note that onSubscribe is not serialized in respect of the other methods so make sure the Subscription is set before any of the other methods are called.
The implementation assumes that the actual Subscriber's methods don't throw.
| Constructor and Description |
|---|
SerializedSubscriber(org.reactivestreams.Subscriber<? super T> actual) |
SerializedSubscriber(org.reactivestreams.Subscriber<? super T> actual,
boolean delayError) |
| Modifier and Type | Method and Description |
|---|---|
void |
onComplete() |
void |
onError(java.lang.Throwable t) |
void |
onNext(T t) |
void |
onSubscribe(org.reactivestreams.Subscription s) |
public SerializedSubscriber(org.reactivestreams.Subscriber<? super T> actual)
public SerializedSubscriber(org.reactivestreams.Subscriber<? super T> actual, boolean delayError)
public void onSubscribe(org.reactivestreams.Subscription s)
onSubscribe in interface org.reactivestreams.Subscriber<T>public void onError(java.lang.Throwable t)
onError in interface org.reactivestreams.Subscriber<T>public void onComplete()
onComplete in interface org.reactivestreams.Subscriber<T>