T - the type of item the Observer expects to observepublic interface Observer<T>
After an Observer calls
subscribe or
subscribe method, the Connector calls the Observer's onNext(T)
method to provide notifications. The Connector should call an
Observer's onCompleted() or onError(java.lang.Throwable) method exactly once.
| Modifier and Type | Method and Description |
|---|---|
void |
onCompleted()
Notifies the Observer that the
Connector has finished sending
push-based notifications. |
void |
onError(Throwable e)
Notifies the Observer that the
Connector has experienced an error
condition. |
void |
onNext(T t)
Provides the Observer with a new item to observe.
|
void onCompleted()
Connector has finished sending
push-based notifications.
The Connector will not call this method if it calls
onError(java.lang.Throwable).
void onError(Throwable e)
Connector has experienced an error
condition.
If the Connector calls this method, it will not thereafter call
onNext(T) or onCompleted().
e - the exception encountered by the Connectorvoid onNext(T t)
The Connector may call this method 0 or more times.
The Connector will not call this method again after it calls
either onCompleted() or onError(java.lang.Throwable).
t - the item emitted by the ConnectorCopyright © 2018–2025. All rights reserved.