Constructor and Description |
---|
DefaultObserver() |
Modifier and Type | Method and Description |
---|---|
protected void |
cancel()
Cancels the upstream's disposable.
|
protected void |
onStart()
Called once the subscription has been set on this observer; override this
to perform initialization.
|
void |
onSubscribe(Disposable s)
Provides the Observer with the means of cancelling (disposing) the
connection (channel) with the Observable in both
synchronous (from within
Observer.onNext(Object) ) and asynchronous manner. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onComplete, onError, onNext
public final void onSubscribe(Disposable s)
Observer
Observer.onNext(Object)
) and asynchronous manner.onSubscribe
in interface Observer<T>
s
- the Disposable instance whose Disposable.dispose()
can
be called anytime to cancel the connectionprotected final void cancel()
protected void onStart()