T - the value typepublic final class NbpFullArbiter<T> extends java.lang.Object implements Disposable
| Constructor and Description |
|---|
NbpFullArbiter(NbpObservable.NbpSubscriber<? super T> actual,
Disposable resource,
int capacity) |
| Modifier and Type | Method and Description |
|---|---|
void |
dispose()
Dispose the resource, the operation should be idempotent.
|
void |
onComplete(Disposable s) |
void |
onError(java.lang.Throwable value,
Disposable s) |
boolean |
onNext(T value,
Disposable s) |
boolean |
setSubscription(Disposable s) |
public NbpFullArbiter(NbpObservable.NbpSubscriber<? super T> actual, Disposable resource, int capacity)
public void dispose()
Disposabledispose in interface Disposablepublic boolean setSubscription(Disposable s)
public boolean onNext(T value, Disposable s)
public void onError(java.lang.Throwable value,
Disposable s)
public void onComplete(Disposable s)