T
- the value typepublic final class BlockingLastObserver<T> extends BlockingBaseObserver<T>
Constructor and Description |
---|
BlockingLastObserver() |
Modifier and Type | Method and Description |
---|---|
void |
onError(Throwable t)
Notifies the Observer that the
Observable has experienced an error condition. |
void |
onNext(T t)
Provides the Observer with a new item to observe.
|
blockingGet, dispose, isDisposed, onComplete, onSubscribe
public void onNext(T t)
Observer
The Observable
may call this method 0 or more times.
The Observable
will not call this method again after it calls either Observer.onComplete()
or
Observer.onError(java.lang.Throwable)
.
t
- the item emitted by the Observablepublic void onError(Throwable t)
Observer
Observable
has experienced an error condition.
If the Observable
calls this method, it will not thereafter call Observer.onNext(T)
or
Observer.onComplete()
.
t
- the exception encountered by the ObservableCopyright © 2018 JBoss by Red Hat. All rights reserved.