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

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

Methods inherited from class java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.Object

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

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 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

next

void next()