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
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.
-
-
-
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
-
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.
-
onCompleted
public void onCompleted()
Description copied from interface:Completable.CompletableSubscriber
Called once the deferred computation completes normally.- Specified by:
onCompleted
in interfaceCompletable.CompletableSubscriber
-
-