TResult- The type of element signaled.
public interface Observer<TResult>
After signaling demand:
onNext(Object)up to the maximum number defined by
onComplete()which signals a terminal state after which no further events will be sent.
|Modifier and Type||Method and Description|
Notifies the Subscriber that the
Notifies the Observer that the
Provides the Observer with a new item to observe.
Invoked on subscription to an
void onSubscribe(Subscription subscription)
No operation will happen until
Subscription.request(long) is invoked.
It is the responsibility of this Subscriber instance to call
Subscription.request(long) whenever more data is wanted.
void onNext(TResult result)
The Observer may call this method 0 or more times.
result- the item emitted by the
void onError(Throwable e)
Observablehas experienced an error condition.
e- the exception encountered by the