T
- type of elementpublic interface Emitter<T> extends Completable
Subscriber
.Modifier and Type | Method and Description |
---|---|
void |
onError(Throwable t)
Failed terminal state.
|
void |
onNext(T t)
Data notification sent by the
Publisher in response to requests to Subscription.request(long) . |
onComplete
void onNext(T t)
Publisher
in response to requests to Subscription.request(long)
.t
- the element signaledvoid onError(Throwable t)
No further events will be sent even if Subscription.request(long)
is invoked again.
t
- the throwable signaled