Modifier and Type	Class and Description
pack-priv static class	CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber

Modifier and Type	Field and Description
pack-priv final Iterable<? extends Completable>	sources

Access	Constructor and Description
public	CompletableOnSubscribeConcatIterable(Iterable<? extends Completable> sources)

Modifier and Type	Method and Description
public void	call(CompletableSubscriber s) Implements rx.functions.Action1.call.

sources	back to summary
pack-priv final Iterable<? extends Completable> sources

CompletableOnSubscribeConcatIterable	back to summary
public CompletableOnSubscribeConcatIterable(Iterable<? extends Completable> sources)

call	back to summary
public void call(CompletableSubscriber s) Implements rx.functions.Action1.call. Annotations @Override

pack-priv final Class CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber

Class Inheritance

extends AtomicInteger
implements CompletableSubscriber

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
rx.internal.operators.CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber

All Implemented Interfaces

Field Summary

Modifier and Type	Field and Description
pack-priv final CompletableSubscriber	actual
pack-priv final SequentialSubscription	sd
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.
pack-priv final Iterator<? extends Completable>	sources

Constructor Summary

Access	Constructor and Description
public	ConcatInnerSubscriber(CompletableSubscriber actual, Iterator<? extends Completable> sources)

Method Summary

Modifier and Type	Method and Description
pack-priv void	next()
public void	onCompleted() Implements rx.CompletableSubscriber.onCompleted. Called once the deferred computation completes normally.
public void	onError(Throwable the exception, not null. e) Implements rx.CompletableSubscriber.onError. Called once if the deferred computation 'throws' an exception.
public void	onSubscribe(Subscription the Subscription instance to call dispose on for cancellation, not null d) Implements rx.CompletableSubscriber.onSubscribe. Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time.

Field Detail

actual	back to summary
pack-priv final CompletableSubscriber actual

sd	back to summary
pack-priv final SequentialSubscription sd

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

sources	back to summary
pack-priv final Iterator<? extends Completable> sources

Constructor Detail

ConcatInnerSubscriber	back to summary
public ConcatInnerSubscriber(CompletableSubscriber actual, Iterator<? extends Completable> sources)

Method Detail

next	back to summary
pack-priv void next()

onCompleted	back to summary
public void onCompleted() Implements rx.CompletableSubscriber.onCompleted. Doc from rx.CompletableSubscriber.onCompleted. Called once the deferred computation completes normally. Annotations @Override

onCompleted

back to summary

public void onCompleted()

Implements rx.CompletableSubscriber.onCompleted.

Doc from rx.CompletableSubscriber.onCompleted.

Called once the deferred computation completes normally.

Annotations

@Override

onError	back to summary
public void onError(Throwable e) Implements rx.CompletableSubscriber.onError. Doc from rx.CompletableSubscriber.onError. Called once if the deferred computation 'throws' an exception. Parameters e:Throwable the exception, not null. Annotations @Override

onError

back to summary

public void onError(Throwable e)

Implements rx.CompletableSubscriber.onError.

Doc from rx.CompletableSubscriber.onError.

Called once if the deferred computation 'throws' an exception.

Parameters

e:Throwable: the exception, not null.

Annotations

@Override

onSubscribe	back to summary
public void onSubscribe(Subscription d) Implements rx.CompletableSubscriber.onSubscribe. Doc from rx.CompletableSubscriber.onSubscribe. Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time. Parameters d:Subscription the Subscription instance to call dispose on for cancellation, not null Annotations @Override

onSubscribe

back to summary

public void onSubscribe(Subscription d)

Implements rx.CompletableSubscriber.onSubscribe.

Doc from rx.CompletableSubscriber.onSubscribe.

Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time.

Parameters