T - public abstract class DisposableSubscriber<T> extends java.lang.Object implements org.reactivestreams.Subscriber<T>, Disposable
| Constructor and Description |
|---|
DisposableSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
cancel() |
void |
dispose()
Dispose the resource, the operation should be idempotent.
|
boolean |
isDisposed() |
protected void |
onStart() |
void |
onSubscribe(org.reactivestreams.Subscription s) |
protected void |
request(long n) |
protected org.reactivestreams.Subscription |
subscription() |
public final void onSubscribe(org.reactivestreams.Subscription s)
onSubscribe in interface org.reactivestreams.Subscriber<T>protected final org.reactivestreams.Subscription subscription()
protected void onStart()
protected final void request(long n)
protected final void cancel()
public final boolean isDisposed()
public final void dispose()
Disposabledispose in interface Disposable