Top Inners Fields Constructors Methods
io.reactivex.internal.operators.completable

public final Class CompletableUsing<R>

extends Completable
Class Inheritance
Imports
java.util.concurrent.Callable, java.util.concurrent.atomic.AtomicReference, io.reactivex.*, io.reactivex.disposables.Disposable, io.reactivex.exceptions.*, io.reactivex.functions.*, io.reactivex.internal.disposables.*, io.reactivex.internal.functions.ObjectHelper, io.reactivex.plugins.RxJavaPlugins

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class

Field Summary

Modifier and TypeField and Description
pack-priv final Function<? super R, ? extends CompletableSource>
pack-priv final Consumer<? super R>
pack-priv final boolean
pack-priv final Callable<R>

Constructor Summary

AccessConstructor and Description
public
CompletableUsing(Callable<R> resourceSupplier, Function<? super R, ? extends CompletableSource> completableFunction, Consumer<? super R> disposer, boolean eager)

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(CompletableObserver
the CompletableObserver instance, never null
observer
)

Implements abstract io.reactivex.Completable.subscribeActual.

Implement this method to handle the incoming CompletableObservers and perform the business logic in your operator.
Inherited from io.reactivex.Completable:
ambambArrayambWithandThenandThenandThenandThenandThenasblockingAwaitblockingAwaitblockingGetblockingGetcachecompletecomposeconcatconcatconcatconcatArrayconcatWithcreatedeferdelaydelaydelaydelaySubscriptiondelaySubscriptiondoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnSubscribedoOnTerminateerrorerrorfromActionfromCallablefromFuturefromMaybefromObservablefromPublisherfromRunnablefromSinglehideliftmaterializemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnonErrorCompleteonErrorCompleteonErrorResumeNextonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryWhenstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribeOnsubscribeWithtakeUntiltesttesttimeouttimeouttimeouttimeouttimertimertotoFlowabletoMaybetoObservabletoSingletoSingleDefaultunsafeCreateunsubscribeOnusingusingwrap

Field Detail

completableFunctionback to summary
pack-priv final Function<? super R, ? extends CompletableSource> completableFunction
disposerback to summary
pack-priv final Consumer<? super R> disposer
eagerback to summary
pack-priv final boolean eager
resourceSupplierback to summary
pack-priv final Callable<R> resourceSupplier

Constructor Detail

CompletableUsingback to summary
public CompletableUsing(Callable<R> resourceSupplier, Function<? super R, ? extends CompletableSource> completableFunction, Consumer<? super R> disposer, boolean eager)

Method Detail

subscribeActualback to summary
protected void subscribeActual(CompletableObserver observer)

Implements abstract io.reactivex.Completable.subscribeActual.

Doc from io.reactivex.Completable.subscribeActual.

Implement this method to handle the incoming CompletableObservers and perform the business logic in your operator.

There is no need to call any of the plugin hooks on the current Completable instance or the CompletableObserver; all hooks and basic safeguards have been applied by subscribe(CompletableObserver) before this method gets called.

Parameters
observer:CompletableObserver

the CompletableObserver instance, never null

Annotations
@Override
io.reactivex.internal.operators.completable back to summary

pack-priv final Class CompletableUsing.UsingObserver<R>

extends AtomicReference<Object>
implements CompletableObserver, Disposable
Class Inheritance
All Implemented Interfaces
io.reactivex.disposables.Disposable, io.reactivex.CompletableObserver

Field Summary

Modifier and TypeField and Description
pack-priv final Consumer<? super R>
pack-priv final CompletableObserver
pack-priv final boolean
private static final long
pack-priv Disposable

Constructor Summary

AccessConstructor and Description
pack-priv
UsingObserver(CompletableObserver actual, R resource, Consumer<? super R> disposer, boolean eager)

Method Summary

Modifier and TypeMethod and Description
public void
dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.
pack-priv void
public boolean
isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.
public void
onComplete()

Implements io.reactivex.CompletableObserver.onComplete.

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

Implements io.reactivex.CompletableObserver.onError.

Called once if the deferred computation 'throws' an exception.
public void
onSubscribe(Disposable
the Disposable instance to call dispose on for cancellation, not null
d
)

Implements io.reactivex.CompletableObserver.onSubscribe.

Called once by the Completable to set a Disposable on this instance which then can be used to cancel the subscription at any time.
Inherited from java.util.concurrent.atomic.AtomicReference:
accumulateAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetgetgetAcquiregetAndAccumulategetAndSetgetAndUpdategetOpaquegetPlainlazySetsetsetOpaquesetPlainsetReleasetoStringupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

disposerback to summary
pack-priv final Consumer<? super R> disposer
downstreamback to summary
pack-priv final CompletableObserver downstream
eagerback to summary
pack-priv final boolean eager
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

upstreamback to summary
pack-priv Disposable upstream

Constructor Detail

UsingObserverback to summary
pack-priv UsingObserver(CompletableObserver actual, R resource, Consumer<? super R> disposer, boolean eager)

Method Detail

disposeback to summary
public void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Doc from io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations
@Override
disposeResourceAfterback to summary
pack-priv void disposeResourceAfter()
Annotations
@SuppressWarnings:unchecked
isDisposedback to summary
public boolean isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Doc from io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations
@Override
onCompleteback to summary
public void onComplete()

Implements io.reactivex.CompletableObserver.onComplete.

Doc from io.reactivex.CompletableObserver.onComplete.

Called once the deferred computation completes normally.

Annotations
@SuppressWarnings:unchecked
@Override
onErrorback to summary
public void onError(Throwable e)

Implements io.reactivex.CompletableObserver.onError.

Doc from io.reactivex.CompletableObserver.onError.

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

Parameters
e:Throwable

the exception, not null.

Annotations
@SuppressWarnings:unchecked
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)

Implements io.reactivex.CompletableObserver.onSubscribe.

Doc from io.reactivex.CompletableObserver.onSubscribe.

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

Parameters
d:Disposable

the Disposable instance to call dispose on for cancellation, not null

Annotations
@Override