Package rx.internal.operators

Class CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

rx.internal.operators.CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber

All Implemented Interfaces:

Serializable, Completable.CompletableSubscriber

Enclosing class:

CompletableOnSubscribeConcatIterable

static final class CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber
extends AtomicInteger
implements Completable.CompletableSubscriber

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Completable.CompletableSubscriber	actual
(package private) int	index
(package private) final SerialSubscription	sd
private static final long	serialVersionUID
(package private) final Iterator<? extends Completable>	sources

Constructor Summary

Constructors

Constructor	Description
ConcatInnerSubscriber(Completable.CompletableSubscriber actual, Iterator<? extends Completable> sources)

Method Summary

Modifier and Type	Method	Description
(package private) void	next()
void	onCompleted()	Called once the deferred computation completes normally.
void	onError(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 Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

actual

final Completable.CompletableSubscriber actual

sources

final Iterator<? extends Completable> sources

index

int index

sd

final SerialSubscription sd

Constructor Details

ConcatInnerSubscriber

public ConcatInnerSubscriber(Completable.CompletableSubscriber actual,
 Iterator<? extends Completable> sources)

Method Details

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