T - the value typepublic final class NbpSerializedSubscriber<T> extends java.lang.Object implements NbpObservable.NbpSubscriber<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 |
|---|
NbpSerializedSubscriber(NbpObservable.NbpSubscriber<? super T> actual) |
NbpSerializedSubscriber(NbpObservable.NbpSubscriber<? 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(Disposable s) |
public NbpSerializedSubscriber(NbpObservable.NbpSubscriber<? super T> actual)
public NbpSerializedSubscriber(NbpObservable.NbpSubscriber<? super T> actual, boolean delayError)
public void onSubscribe(Disposable s)
onSubscribe in interface NbpObservable.NbpSubscriber<T>public void onNext(T t)
onNext in interface NbpObservable.NbpSubscriber<T>public void onError(java.lang.Throwable t)
onError in interface NbpObservable.NbpSubscriber<T>public void onComplete()
onComplete in interface NbpObservable.NbpSubscriber<T>