onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher#subscribe(Subscriber).
No further notifications will be received until Subscription#request(long) is called.
After signaling demand:
onNext(Object) up to the maximum number defined by Subscription#request(long)onError(Throwable) or Subscriber#onComplete() which signals a terminal state after which no further events will be sent.
Demand can be signaled via Subscription#request(long) whenever the Subscriber instance is capable of handling more.
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| public void | |
| public void | onNext(T
the element signaled t)Data notification sent by the |
| public void | onSubscribe(Subscription
the s)Subscription that allows requesting data via Subscription#request(long)Invoked after calling |
| onComplete | back to summary |
|---|---|
| public void onComplete() Successful terminal state.
No further events will be sent even if | |
| onError | back to summary |
|---|---|
| public void onError(Throwable t) Failed terminal state.
No further events will be sent even if
| |
| onNext | back to summary |
|---|---|
| public void onNext(T t) Data notification sent by the
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(Subscription s) Invoked after calling
No data will start flowing until
It is the responsibility of this
The
| |