Package rx.internal.operators
Class CompletableOnSubscribeConcatArray.ConcatInnerSubscriber
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicInteger
-
- rx.internal.operators.CompletableOnSubscribeConcatArray.ConcatInnerSubscriber
-
- All Implemented Interfaces:
java.io.Serializable
,Completable.CompletableSubscriber
- Enclosing class:
- CompletableOnSubscribeConcatArray
static final class CompletableOnSubscribeConcatArray.ConcatInnerSubscriber extends java.util.concurrent.atomic.AtomicInteger implements Completable.CompletableSubscriber
-
-
Field Summary
Fields Modifier and Type Field Description (package private) Completable.CompletableSubscriber
actual
(package private) int
index
(package private) SerialSubscription
sd
private static long
serialVersionUID
(package private) Completable[]
sources
-
Constructor Summary
Constructors Constructor Description ConcatInnerSubscriber(Completable.CompletableSubscriber actual, Completable[] sources)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
next()
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.util.concurrent.atomic.AtomicInteger
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
actual
final Completable.CompletableSubscriber actual
-
sources
final Completable[] sources
-
index
int index
-
sd
final SerialSubscription sd
-
-
Constructor Detail
-
ConcatInnerSubscriber
public ConcatInnerSubscriber(Completable.CompletableSubscriber actual, Completable[] sources)
-
-
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
-
next
void next()
-
-