Package rx.internal.operators

Class CompletableOnSubscribeConcat.CompletableConcatSubscriber.ConcatInnerSubscriber

java.lang.Object

rx.internal.operators.CompletableOnSubscribeConcat.CompletableConcatSubscriber.ConcatInnerSubscriber

All Implemented Interfaces:

Completable.CompletableSubscriber

Enclosing class:

CompletableOnSubscribeConcat.CompletableConcatSubscriber

final class CompletableOnSubscribeConcat.CompletableConcatSubscriber.ConcatInnerSubscriber
extends java.lang.Object
implements Completable.CompletableSubscriber

Constructor Summary

Constructors

Constructor	Description
ConcatInnerSubscriber()

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

Constructor Detail

ConcatInnerSubscriber

ConcatInnerSubscriber()

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

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.

onCompleted

public void onCompleted()

Description copied from interface: Completable.CompletableSubscriber

Called once the deferred computation completes normally.

Specified by:

onCompleted in interface Completable.CompletableSubscriber