TResult- The type of element signaled.
public interface Observer<TResult>
Will receive a call to
onSubscribe(Subscription) on subscription to the
No further notifications will be received until
Subscription.request(long) is called.
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.
Demand can be signaled via
Subscription.request(long) whenever the
Observer instance is capable of handling more.
|Modifier and Type||Method||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.
MongoIterable will send notifications only in response to
Subscriptionthat allows requesting data via
void onNext(TResult result)
The Observer may call this method 0 or more times.
Observable will not call this method again after it calls either
result- the item emitted by the
void onError(Throwable e)
Observablehas experienced an error condition.
Observable calls this method, it will not thereafter call
e- the exception encountered by the
Observablehas finished sending push-based notifications.
Observable will not call this method if it calls