Package rx.internal.operators
Class OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber
- java.lang.Object
-
- rx.internal.operators.OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber
-
- All Implemented Interfaces:
Completable.CompletableSubscriber
- Enclosing class:
- OnSubscribeOnAssemblyCompletable<T>
static final class OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber extends java.lang.Object implements Completable.CompletableSubscriber
-
-
Field Summary
Fields Modifier and Type Field Description (package private) Completable.CompletableSubscriber
actual
(package private) java.lang.String
stacktrace
-
Constructor Summary
Constructors Constructor Description OnAssemblyCompletableSubscriber(Completable.CompletableSubscriber actual, java.lang.String stacktrace)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onCompleted()
Called once the deferred computation completes normally.void
onError(java.lang.Throwable e)
Called once if the deferred computation 'throws' an exception.void
onSubscribe(Subscription d)
Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time.
-
-
-
Field Detail
-
actual
final Completable.CompletableSubscriber actual
-
stacktrace
final java.lang.String stacktrace
-
-
Constructor Detail
-
OnAssemblyCompletableSubscriber
public OnAssemblyCompletableSubscriber(Completable.CompletableSubscriber actual, java.lang.String stacktrace)
-
-
Method Detail
-
onSubscribe
public void onSubscribe(Subscription d)
Description copied from interface:Completable.CompletableSubscriber
Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time.- Specified by:
onSubscribe
in interfaceCompletable.CompletableSubscriber
- Parameters:
d
- the Subscription instance to call dispose on for cancellation, not null
-
onCompleted
public void onCompleted()
Description copied from interface:Completable.CompletableSubscriber
Called once the deferred computation completes normally.- Specified by:
onCompleted
in interfaceCompletable.CompletableSubscriber
-
onError
public void onError(java.lang.Throwable e)
Description copied from interface:Completable.CompletableSubscriber
Called once if the deferred computation 'throws' an exception.- Specified by:
onError
in interfaceCompletable.CompletableSubscriber
- Parameters:
e
- the exception, not null.
-
-