Top Inners Fields Constructors Methods
rx.internal.operators

public final Class CompletableFlatMapSingleToCompletable<T>

extends Object
implements OnSubscribe
Class Inheritance
All Implemented Interfaces
rx.Completable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Imports
rx.Completable, .Completable.OnSubscribe, .CompletableSubscriber, .Single, .SingleSubscriber, .Subscription, rx.exceptions.Exceptions, rx.functions.Func1

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
CompletableFlatMapSingleToCompletable.SourceSubscriber<T>

Field Summary

Modifier and TypeField and Description
pack-priv final Func1<? super T, ? extends Completable>
mapper

pack-priv final Single<T>
source

Constructor Summary

AccessConstructor and Description
public
CompletableFlatMapSingleToCompletable(Single<T> source, Func1<? super T, ? extends Completable> mapper)

Method Summary

Modifier and TypeMethod and Description
public void
call(CompletableSubscriber t)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

mapperback to summary
pack-priv final Func1<? super T, ? extends Completable> mapper
sourceback to summary
pack-priv final Single<T> source

Constructor Detail

CompletableFlatMapSingleToCompletableback to summary
public CompletableFlatMapSingleToCompletable(Single<T> source, Func1<? super T, ? extends Completable> mapper)

Method Detail

callback to summary
public void call(CompletableSubscriber t)

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv final Class CompletableFlatMapSingleToCompletable.SourceSubscriber<T>

extends SingleSubscriber<T>
implements CompletableSubscriber
Class Inheritance
All Implemented Interfaces
rx.CompletableSubscriber

Field Summary

Modifier and TypeField and Description
pack-priv final CompletableSubscriber
actual

pack-priv final Func1<? super T, ? extends Completable>
mapper

Constructor Summary

AccessConstructor and Description
public
SourceSubscriber(CompletableSubscriber actual, Func1<? super T, ? extends Completable> mapper)

Method Summary

Modifier and TypeMethod and Description
public void
onCompleted()

Implements rx.CompletableSubscriber.onCompleted.

Called once the deferred computation completes normally.
public void
onError(Throwable
the exception, not null.
error)

Implements abstract rx.SingleSubscriber.onError.

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.
public void
onSuccess(T
the item emitted by the Single
value)

Implements abstract rx.SingleSubscriber.onSuccess.

Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.
Inherited from rx.SingleSubscriber:
addisUnsubscribedunsubscribe

Field Detail

actualback to summary
pack-priv final CompletableSubscriber actual
mapperback to summary
pack-priv final Func1<? super T, ? extends Completable> mapper

Constructor Detail

SourceSubscriberback to summary
public SourceSubscriber(CompletableSubscriber actual, Func1<? super T, ? extends Completable> mapper)

Method Detail

onCompletedback to summary
public void onCompleted()

Implements rx.CompletableSubscriber.onCompleted.

Doc from rx.CompletableSubscriber.onCompleted.

Called once the deferred computation completes normally.

Annotations
@Override
onErrorback to summary
public void onError(Throwable error)

Implements abstract rx.SingleSubscriber.onError.

Implements rx.CompletableSubscriber.onError.

Doc from rx.CompletableSubscriber.onError.

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

Parameters
error:Throwable

the exception, not null.

Annotations
@Override
onSubscribeback 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
onSuccessback to summary
public void onSuccess(T value)

Implements abstract rx.SingleSubscriber.onSuccess.

Doc from rx.SingleSubscriber.onSuccess.

Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.

The Single will not call this method if it calls onError.

Parameters
value:T

the item emitted by the Single

Annotations
@Override