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

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 interface Completable.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 interface Completable.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 interface Completable.CompletableSubscriber

Parameters:

e - the exception, not null.