public final class SubscriberCompletableObserver<T> extends Object implements CompletableObserver, org.reactivestreams.Subscription
Constructor and Description |
---|
SubscriberCompletableObserver(org.reactivestreams.Subscriber<? super T> observer) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
void |
onComplete()
Called once the deferred computation completes normally.
|
void |
onError(Throwable e)
Called once if the deferred computation 'throws' an exception.
|
void |
onSubscribe(Disposable d)
Called once by the Completable to set a Disposable on this instance which
then can be used to cancel the subscription at any time.
|
void |
request(long n) |
public SubscriberCompletableObserver(org.reactivestreams.Subscriber<? super T> observer)
public void onComplete()
CompletableObserver
onComplete
in interface CompletableObserver
public void onError(Throwable e)
CompletableObserver
onError
in interface CompletableObserver
e
- the exception, not null.public void onSubscribe(Disposable d)
CompletableObserver
onSubscribe
in interface CompletableObserver
d
- the Disposable instance to call dispose on for cancellation, not nullpublic void request(long n)
request
in interface org.reactivestreams.Subscription
public void cancel()
cancel
in interface org.reactivestreams.Subscription
Copyright © 2018 JBoss by Red Hat. All rights reserved.