public abstract class DisposableCompletableObserver extends java.lang.Object implements CompletableObserver, io.reactivex.common.Disposable
CompletableObserver that allows asynchronous cancellation by implementing Disposable.
All pre-implemented final methods are thread-safe.
Like all other consumers, DisposableCompletableObserver can be subscribed only once.
Any subsequent attempt to subscribe it to a new source will yield an
IllegalStateException with message "Disposable already set!".
Implementation of onStart(), CompletableObserver.onError(Throwable) and
CompletableObserver.onComplete() are not allowed to throw any unchecked exceptions.
Example
Disposable d =
Completable.complete().delay(1, TimeUnit.SECONDS)
.subscribeWith(new DisposableMaybeObserver<Integer>() {
@Override public void onStart() {
System.out.println("Start!");
}
@Override public void onError(Throwable t) {
t.printStackTrace();
}
@Override public void onComplete() {
System.out.println("Done!");
}
});
// ...
d.dispose();
| Constructor and Description |
|---|
DisposableCompletableObserver() |
| Modifier and Type | Method and Description |
|---|---|
void |
dispose() |
boolean |
isDisposed() |
protected void |
onStart()
Called once the single upstream Disposable is set via onSubscribe.
|
void |
onSubscribe(io.reactivex.common.Disposable s)
Called once by the Completable to set a Disposable on this instance which
then can be used to cancel the subscription at any time.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonComplete, onErrorpublic final void onSubscribe(@NonNull
io.reactivex.common.Disposable s)
CompletableObserveronSubscribe in interface CompletableObservers - the Disposable instance to call dispose on for cancellation, not nullprotected void onStart()
public final boolean isDisposed()
isDisposed in interface io.reactivex.common.Disposablepublic final void dispose()
dispose in interface io.reactivex.common.Disposable