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

public final Class CompletableTimeout

extends Completable
Class Inheritance
Static Imports
io.reactivex.rxjava3.internal.util.ExceptionHelper.timeoutMessage

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
CompletableTimeout.DisposeTask

pack-priv static class
CompletableTimeout.TimeOutObserver

Field Summary

Modifier and TypeField and Description
pack-priv final CompletableSource
other

pack-priv final Scheduler
scheduler

pack-priv final CompletableSource
source

pack-priv final long
timeout

pack-priv final TimeUnit
unit

Constructor Summary

AccessConstructor and Description
public
CompletableTimeout(CompletableSource source, long timeout, TimeUnit unit, Scheduler scheduler, CompletableSource other)

Method Summary

Modifier and TypeMethod and Description
public void
subscribeActual(final CompletableObserver observer)

Inherited from io.reactivex.rxjava3.core.Completable:
ambambArrayambWithandThenandThenandThenandThenandThenblockingAwaitblockingAwaitblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribecachecompletecomposeconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatWithcreatedeferdelaydelaydelaydelaySubscriptiondelaySubscriptiondoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnLifecycledoOnSubscribedoOnTerminateerrorerrorfromActionfromCallablefromCompletionStagefromFuturefromMaybefromObservablefromPublisherfromRunnablefromSinglefromSupplierhideliftmaterializemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeWithonErrorReturnonErrorReturnItemonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensafeSubscribesequenceEqualstartWithstartWithstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribesubscribeActualsubscribeOnsubscribeWithswitchOnNextswitchOnNextDelayErrortakeUntiltesttesttimeouttimeouttimeouttimeouttimertimertotoCompletionStagetoFlowabletoFuturetoMaybetoObservabletoSingletoSingleDefaultunsafeCreateunsubscribeOnusingusingwrap

Field Detail

otherback to summary
pack-priv final CompletableSource other
schedulerback to summary
pack-priv final Scheduler scheduler
sourceback to summary
pack-priv final CompletableSource source
timeoutback to summary
pack-priv final long timeout
unitback to summary
pack-priv final TimeUnit unit

Constructor Detail

CompletableTimeoutback to summary
public CompletableTimeout(CompletableSource source, long timeout, TimeUnit unit, Scheduler scheduler, CompletableSource other)

Method Detail

subscribeActualback to summary
public void subscribeActual(final CompletableObserver observer)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.completable back to summary

pack-priv final Class CompletableTimeout.DisposeTask

extends Object
implements Runnable
Class Inheritance
  • java.lang.Object
  • io.reactivex.rxjava3.internal.operators.completable.CompletableTimeout.DisposeTask
All Implemented Interfaces
java.lang.Runnable

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
CompletableTimeout.DisposeTask.DisposeObserver

Field Summary

Modifier and TypeField and Description
pack-priv final CompletableObserver
downstream

private final AtomicBoolean
once

pack-priv final CompositeDisposable
set

Constructor Summary

AccessConstructor and Description
pack-priv
DisposeTask(AtomicBoolean once, CompositeDisposable set, CompletableObserver observer)

Method Summary

Modifier and TypeMethod and Description
public void
run()

Implements java.lang.Runnable.run.

Runs this operation.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

downstreamback to summary
pack-priv final CompletableObserver downstream
onceback to summary
private final AtomicBoolean once
setback to summary
pack-priv final CompositeDisposable set

Constructor Detail

DisposeTaskback to summary
pack-priv DisposeTask(AtomicBoolean once, CompositeDisposable set, CompletableObserver observer)

Method Detail

runback to summary
public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

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

pack-priv final Class CompletableTimeout.DisposeTask.DisposeObserver

extends Object
implements CompletableObserver
Class Inheritance
  • java.lang.Object
  • io.reactivex.rxjava3.internal.operators.completable.CompletableTimeout.DisposeTask.DisposeObserver
All Implemented Interfaces
io.reactivex.rxjava3.core.CompletableObserver

Constructor Summary

AccessConstructor and Description
pack-priv
DisposeObserver()

Method Summary

Modifier and TypeMethod and Description
public void
onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.
public void
onError(Throwable e)

public void
onSubscribe(Disposable d)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

DisposeObserverback to summary
pack-priv DisposeObserver()

Method Detail

onCompleteback to summary
public void onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Doc from io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)
Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.completable back to summary

pack-priv final Class CompletableTimeout.TimeOutObserver

extends Object
implements CompletableObserver
Class Inheritance
  • java.lang.Object
  • io.reactivex.rxjava3.internal.operators.completable.CompletableTimeout.TimeOutObserver
All Implemented Interfaces
io.reactivex.rxjava3.core.CompletableObserver

Field Summary

Modifier and TypeField and Description
private final CompletableObserver
downstream

private final AtomicBoolean
once

private final CompositeDisposable
set

Constructor Summary

AccessConstructor and Description
pack-priv
TimeOutObserver(CompositeDisposable set, AtomicBoolean once, CompletableObserver observer)

Method Summary

Modifier and TypeMethod and Description
public void
onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.
public void
onError(Throwable e)

public void
onSubscribe(Disposable d)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

downstreamback to summary
private final CompletableObserver downstream
onceback to summary
private final AtomicBoolean once
setback to summary
private final CompositeDisposable set

Constructor Detail

TimeOutObserverback to summary
pack-priv TimeOutObserver(CompositeDisposable set, AtomicBoolean once, CompletableObserver observer)

Method Detail

onCompleteback to summary
public void onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Doc from io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)
Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)
Annotations
@Override