public abstract class Observer<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>
| Constructor and Description |
|---|
Observer() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
cancel() |
protected void |
onStart()
Called once the subscription has been set on this observer; override this
to perform initialization or issue an initial request.
|
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 final void request(long n)
protected final void cancel()
protected void onStart()
The default implementation requests Long.MAX_VALUE.