Uses of Class
io.reactivex.rxjava3.core.Completable

Packages that use Completable

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.operators.completable
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.mixed
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.single
io.reactivex.rxjava3.internal.schedulers
io.reactivex.rxjava3.plugins	Contains the central plugin handler RxJavaPlugins class to hook into the lifecycle of the base reactive types and schedulers.
io.reactivex.rxjava3.subjects	Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind.

Uses of Completable in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core that return Completable

Modifier and Type	Method	Description
static @NonNull Completable	Completable.amb(@NonNull Iterable<@NonNull ? extends CompletableSource> sources)	Returns a Completable which terminates as soon as one of the source Completables in the Iterable sequence terminates (normally or with an error) and disposes all other Completables.
static @NonNull Completable	Completable.ambArray(@NonNull CompletableSource... sources)	Returns a Completable which terminates as soon as one of the source Completables terminates (normally or with an error) and disposes all other Completables.
final @NonNull Completable	Completable.ambWith(@NonNull CompletableSource other)	Returns a Completable that emits the a terminated event of either this Completable or the other CompletableSource, whichever fires first.
final @NonNull Completable	Completable.andThen(@NonNull CompletableSource next)	Returns a Completable that first runs this Completable and then the other CompletableSource.
final @NonNull Completable	Completable.cache()	Subscribes to this Completable only once, when the first CompletableObserver subscribes to the result Completable, caches its terminal event and relays/replays it to observers.
static @NonNull Completable	Completable.complete()	Returns a Completable instance that completes immediately when subscribed to.
final @NonNull Completable	Completable.compose(@NonNull CompletableTransformer transformer)	Calls the given transformer function with this instance and returns the function's resulting CompletableSource wrapped with Completable.wrap(CompletableSource).
static @NonNull Completable	Completable.concat(@NonNull Iterable<@NonNull ? extends CompletableSource> sources)	Returns a Completable which completes only when all sources complete, one after another.
static @NonNull Completable	Completable.concat(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources)	Returns a Completable which completes only when all sources complete, one after another.
static @NonNull Completable	Completable.concat(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources, int prefetch)	Returns a Completable which completes only when all sources complete, one after another.
static @NonNull Completable	Completable.concatArray(@NonNull CompletableSource... sources)	Returns a Completable which completes only when all sources complete, one after another.
static @NonNull Completable	Completable.concatArrayDelayError(@NonNull CompletableSource... sources)	Returns a Completable which completes only when all sources complete, one after another.
static @NonNull Completable	Completable.concatDelayError(@NonNull Iterable<@NonNull ? extends CompletableSource> sources)	Returns a Completable which completes only when all sources complete, one after another.
static @NonNull Completable	Completable.concatDelayError(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources)	Returns a Completable which completes only when all sources complete, one after another.
static @NonNull Completable	Completable.concatDelayError(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources, int prefetch)	Returns a Completable which completes only when all sources complete, one after another.
final @NonNull Completable	Flowable.concatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps the upstream items into CompletableSources and subscribes to them one after the other completes.
final @NonNull Completable	Flowable.concatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, int prefetch)	Maps the upstream items into CompletableSources and subscribes to them one after the other completes.
final @NonNull Completable	Maybe.concatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Returns a Completable that completes based on applying a specified function to the item emitted by the current Maybe, where that function returns a Completable.
final @NonNull Completable	Observable.concatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps each element of the current Observable into CompletableSources, subscribes to them one at a time in order and waits until the upstream and all CompletableSources complete.
final @NonNull Completable	Observable.concatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, int capacityHint)	Maps each element of the current Observable into CompletableSources, subscribes to them one at a time in order and waits until the upstream and all CompletableSources complete.
final @NonNull Completable	Single.concatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Returns a Completable that completes based on applying a specified function to the item emitted by the current Single, where that function returns a CompletableSource.
final @NonNull Completable	Flowable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps the upstream items into CompletableSources and subscribes to them one after the other terminates, delaying all errors till both this Flowable and all inner CompletableSources terminate.
final @NonNull Completable	Flowable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean tillTheEnd)	Maps the upstream items into CompletableSources and subscribes to them one after the other terminates, optionally delaying all errors till both this Flowable and all inner CompletableSources terminate.
final @NonNull Completable	Flowable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean tillTheEnd, int prefetch)	Maps the upstream items into CompletableSources and subscribes to them one after the other terminates, optionally delaying all errors till both this Flowable and all inner CompletableSources terminate.
final @NonNull Completable	Observable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps the upstream items into CompletableSources and subscribes to them one after the other terminates, delaying all errors till both the current Observable and all inner CompletableSources terminate.
final @NonNull Completable	Observable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean tillTheEnd)	Maps the upstream items into CompletableSources and subscribes to them one after the other terminates, optionally delaying all errors till both the current Observable and all inner CompletableSources terminate.
final @NonNull Completable	Observable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean tillTheEnd, int bufferSize)	Maps the upstream items into CompletableSources and subscribes to them one after the other terminates, optionally delaying all errors till both the current Observable and all inner CompletableSources terminate.
final @NonNull Completable	Completable.concatWith(@NonNull CompletableSource other)	Concatenates this Completable with another CompletableSource.
static @NonNull Completable	Completable.create(@NonNull CompletableOnSubscribe source)	Provides an API (via a cold Completable) that bridges the reactive world with the callback-style world.
static @NonNull Completable	Completable.defer(@NonNull Supplier<? extends @NonNull CompletableSource> supplier)	Defers the subscription to a Completable instance returned by a supplier.
final @NonNull Completable	Completable.delay(long time, @NonNull TimeUnit unit)	Returns a Completable which delays the emission of the completion event by the given time.
final @NonNull Completable	Completable.delay(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler)	Returns a Completable which delays the emission of the completion event by the given time while running on the specified Scheduler.
final @NonNull Completable	Completable.delay(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError)	Returns a Completable which delays the emission of the completion event, and optionally the error as well, by the given time while running on the specified Scheduler.
final @NonNull Completable	Completable.delaySubscription(long time, @NonNull TimeUnit unit)	Returns a Completable that delays the subscription to the upstream by a given amount of time.
final @NonNull Completable	Completable.delaySubscription(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler)	Returns a Completable that delays the subscription to the upstream by a given amount of time, both waiting and subscribing on a given Scheduler.
final @NonNull Completable	Completable.doAfterTerminate(@NonNull Action onAfterTerminate)	Returns a Completable instance that calls the given onAfterTerminate Action after this Completable completes normally or with an exception.
final @NonNull Completable	Completable.doFinally(@NonNull Action onFinally)	Calls the specified Action after this Completable signals onError or onComplete or gets disposed by the downstream.
final @NonNull Completable	Completable.doOnComplete(@NonNull Action onComplete)	Returns a Completable which calls the given onComplete Action if this Completable completes.
final @NonNull Completable	Completable.doOnDispose(@NonNull Action onDispose)	Calls the shared Action if a CompletableObserver subscribed to the current Completable disposes the common Disposable it received via onSubscribe.
final @NonNull Completable	Completable.doOnError(@NonNull Consumer<? super Throwable> onError)	Returns a Completable which calls the given onError Consumer if this Completable emits an error.
final @NonNull Completable	Completable.doOnEvent(@NonNull Consumer<@Nullable ? super Throwable> onEvent)	Returns a Completable which calls the given onEvent Consumer with the Throwable for an onError or null for an onComplete signal from this Completable before delivering the signal to the downstream.
final @NonNull Completable	Completable.doOnLifecycle(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose)	Calls the appropriate onXXX method (shared between all CompletableObservers) for the lifecycle events of the sequence (subscription, disposal).
private @NonNull Completable	Completable.doOnLifecycle(Consumer<? super Disposable> onSubscribe, Consumer<? super Throwable> onError, Action onComplete, Action onTerminate, Action onAfterTerminate, Action onDispose)	Returns a Completable instance that calls the various callbacks upon the specific lifecycle events.
final @NonNull Completable	Completable.doOnSubscribe(@NonNull Consumer<? super Disposable> onSubscribe)	Returns a Completable instance that calls the given onSubscribe callback with the disposable that the downstream CompletableObservers receive upon subscription.
final @NonNull Completable	Completable.doOnTerminate(@NonNull Action onTerminate)	Returns a Completable instance that calls the given onTerminate Action just before this Completable completes normally or with an exception.
static @NonNull Completable	Completable.error(@NonNull Supplier<? extends @NonNull Throwable> supplier)	Creates a Completable which calls the given error supplier for each subscriber and emits its returned Throwable.
static @NonNull Completable	Completable.error(@NonNull Throwable throwable)	Creates a Completable instance that emits the given Throwable exception to subscribers.
final @NonNull Completable	Flowable.flatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps each element of the upstream Flowable into CompletableSources, subscribes to them and waits until the upstream and all CompletableSources complete.
final @NonNull Completable	Flowable.flatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency)	Maps each element of the upstream Flowable into CompletableSources, subscribes to them and waits until the upstream and all CompletableSources complete, optionally delaying all errors.
final @NonNull Completable	Maybe.flatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Returns a Completable that completes based on applying a specified function to the item emitted by the current Maybe, where that function returns a Completable.
final @NonNull Completable	Observable.flatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps each element of the current Observable into CompletableSources, subscribes to them and waits until the upstream and all CompletableSources complete.
final @NonNull Completable	Observable.flatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean delayErrors)	Maps each element of the current Observable into CompletableSources, subscribes to them and waits until the upstream and all CompletableSources complete, optionally delaying all errors.
final @NonNull Completable	Single.flatMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Returns a Completable that completes based on applying a specified function to the item emitted by the current Single, where that function returns a CompletableSource.
static @NonNull Completable	Completable.fromAction(@NonNull Action action)	Returns a Completable instance that runs the given Action for each CompletableObserver and emits either an exception or simply completes.
static @NonNull Completable	Completable.fromCallable(@NonNull Callable<?> callable)	Returns a Completable which when subscribed, executes the Callable function, ignores its normal result and emits onError or onComplete only.
static @NonNull Completable	Completable.fromCompletionStage(@NonNull CompletionStage<?> stage)	Signals completion (or error) when the CompletionStage terminates.
static @NonNull Completable	Completable.fromFuture(@NonNull Future<?> future)	Returns a Completable instance that reacts to the termination of the given Future in a blocking fashion.
static <@NonNull T> @NonNull Completable	Completable.fromMaybe(@NonNull MaybeSource<@NonNull T> maybe)	Returns a Completable instance that when subscribed to, subscribes to the MaybeSource instance and emits an onComplete event if the maybe emits onSuccess/onComplete or forwards any onError events.
static <@NonNull T> @NonNull Completable	Completable.fromObservable(@NonNull ObservableSource<@NonNull T> observable)	Returns a Completable instance that subscribes to the given ObservableSource, ignores all values and emits only the terminal event.
static <@NonNull T> @NonNull Completable	Completable.fromPublisher(@NonNull org.reactivestreams.Publisher<@NonNull T> publisher)	Returns a Completable instance that subscribes to the given Publisher, ignores all values and emits only the terminal event.
static @NonNull Completable	Completable.fromRunnable(@NonNull Runnable run)	Returns a Completable instance that runs the given Runnable for each CompletableObserver and emits either its unchecked exception or simply completes.
static <@NonNull T> @NonNull Completable	Completable.fromSingle(@NonNull SingleSource<@NonNull T> single)	Returns a Completable instance that when subscribed to, subscribes to the SingleSource instance and emits a completion event if the single emits onSuccess or forwards any onError events.
static @NonNull Completable	Completable.fromSupplier(@NonNull Supplier<?> supplier)	Returns a Completable which when subscribed, executes the Supplier function, ignores its normal result and emits onError or onComplete only.
final @NonNull Completable	Completable.hide()	Hides the identity of this Completable and its Disposable.
final @NonNull Completable	Maybe.ignoreElement()	Returns a Completable that ignores the item emitted by the current Maybe and only calls onComplete or onError.
final @NonNull Completable	Single.ignoreElement()	Returns a Completable that ignores the success value of this Single and signals onComplete instead.
final @NonNull Completable	Flowable.ignoreElements()	Ignores all items emitted by the current Flowable and only calls onComplete or onError.
final @NonNull Completable	Observable.ignoreElements()	Ignores all items emitted by the current Observable and only calls onComplete or onError.
final @NonNull Completable	Completable.lift(@NonNull CompletableOperator onLift)	This method requires advanced knowledge about building operators, please consider other standard composition methods first; Returns a Completable which, when subscribed to, invokes the apply(CompletableObserver) method of the provided CompletableOperator for each individual downstream Completable and allows the insertion of a custom operator by accessing the downstream's CompletableObserver during this subscription phase and providing a new CompletableObserver, containing the custom operator's intended business logic, that will be used in the subscription process going further upstream.
static @NonNull Completable	Completable.merge(@NonNull Iterable<@NonNull ? extends CompletableSource> sources)	Returns a Completable instance that subscribes to all sources at once and completes only when all source CompletableSources complete or one of them emits an error.
static @NonNull Completable	Completable.merge(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources)	Returns a Completable instance that subscribes to all sources at once and completes only when all source CompletableSources complete or one of them emits an error.
static @NonNull Completable	Completable.merge(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources, int maxConcurrency)	Returns a Completable instance that keeps subscriptions to a limited number of sources at once and completes only when all source CompletableSources complete or one of them emits an error.
private static @NonNull Completable	Completable.merge0(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources, int maxConcurrency, boolean delayErrors)	Returns a Completable instance that keeps subscriptions to a limited number of CompletableSources at once and completes only when all source CompletableSources terminate in one way or another, combining any exceptions signaled by either the source Publisher or the inner CompletableSource instances.
static @NonNull Completable	Completable.mergeArray(@NonNull CompletableSource... sources)	Returns a Completable instance that subscribes to all sources at once and completes only when all source CompletableSources complete or one of them emits an error.
static @NonNull Completable	Completable.mergeArrayDelayError(@NonNull CompletableSource... sources)	Returns a Completable that subscribes to all CompletableSources in the source array and delays any error emitted by any of the inner CompletableSources until all of them terminate in a way or another.
static @NonNull Completable	Completable.mergeDelayError(@NonNull Iterable<@NonNull ? extends CompletableSource> sources)	Returns a Completable that subscribes to all CompletableSources in the source sequence and delays any error emitted by any of the inner CompletableSources until all of them terminate in a way or another.
static @NonNull Completable	Completable.mergeDelayError(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources)	Returns a Completable that subscribes to all CompletableSources in the source sequence and delays any error emitted by either the sources Publisher or any of the inner CompletableSources until all of them terminate in a way or another.
static @NonNull Completable	Completable.mergeDelayError(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources, int maxConcurrency)	Returns a Completable that subscribes to a limited number of inner CompletableSources at once in the source sequence and delays any error emitted by either the sources Publisher or any of the inner CompletableSources until all of them terminate in a way or another.
final @NonNull Completable	Completable.mergeWith(@NonNull CompletableSource other)	Returns a Completable which subscribes to this and the other CompletableSource and completes when both of them complete or one emits an error.
static @NonNull Completable	Completable.never()	Returns a Completable that never calls onError or onComplete.
final @NonNull Completable	Completable.observeOn(@NonNull Scheduler scheduler)	Returns a Completable which emits the terminal events from the thread of the specified Scheduler.
final @NonNull Completable	Completable.onErrorComplete()	Returns a Completable instance that if this Completable emits an error, it will emit an onComplete and swallow the upstream Throwable.
final @NonNull Completable	Completable.onErrorComplete(@NonNull Predicate<? super Throwable> predicate)	Returns a Completable instance that if this Completable emits an error and the Predicate returns true, it will emit an onComplete and swallow the Throwable.
final @NonNull Completable	Completable.onErrorResumeNext(@NonNull Function<? super Throwable, ? extends CompletableSource> fallbackSupplier)	Returns a Completable instance that when encounters an error from this Completable, calls the specified mapper Function that returns a CompletableSource instance for it and resumes the execution with it.
final @NonNull Completable	Completable.onErrorResumeWith(@NonNull CompletableSource fallback)	Resumes the flow with the given CompletableSource when the current Completable fails instead of signaling the error via onError.
final @NonNull Completable	Completable.onTerminateDetach()	Nulls out references to the upstream producer and downstream CompletableObserver if the sequence is terminated or downstream calls dispose().
final @NonNull Completable	Completable.repeat()	Returns a Completable that repeatedly subscribes to this Completable until disposed.
final @NonNull Completable	Completable.repeat(long times)	Returns a Completable that subscribes repeatedly at most the given number of times to this Completable.
final @NonNull Completable	Completable.repeatUntil(@NonNull BooleanSupplier stop)	Returns a Completable that repeatedly subscribes to this Completable so long as the given stop BooleanSupplier returns false.
final @NonNull Completable	Completable.repeatWhen(@NonNull Function<? super Flowable<Object>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler)	Returns a Completable instance that repeats when the Publisher returned by the handler Function emits an item or completes when this Publisher emits an onComplete event.
final @NonNull Completable	Completable.retry()	Returns a Completable that retries this Completable as long as it emits an onError event.
final @NonNull Completable	Completable.retry(long times)	Returns a Completable that when this Completable emits an error, retries at most the given number of times before giving up and emitting the last error.
final @NonNull Completable	Completable.retry(long times, @NonNull Predicate<? super Throwable> predicate)	Returns a Completable that when this Completable emits an error, retries at most times or until the predicate returns false, whichever happens first and emitting the last error.
final @NonNull Completable	Completable.retry(@NonNull BiPredicate<? super Integer, ? super Throwable> predicate)	Returns a Completable that retries this Completable in case of an error as long as the predicate returns true.
final @NonNull Completable	Completable.retry(@NonNull Predicate<? super Throwable> predicate)	Returns a Completable that when this Completable emits an error, calls the given predicate with the latest Throwable to decide whether to resubscribe to the upstream or not.
final @NonNull Completable	Completable.retryUntil(@NonNull BooleanSupplier stop)	Retries until the given stop function returns true.
final @NonNull Completable	Completable.retryWhen(@NonNull Function<? super Flowable<Throwable>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler)	Returns a Completable which given a Publisher and when this Completable emits an error, delivers that error through a Flowable and the Publisher should signal a value indicating a retry in response or a terminal event indicating a termination.
final @NonNull Completable	Completable.startWith(@NonNull CompletableSource other)	Returns a Completable which first runs the other CompletableSource then the current Completable if the other completed normally.
final @NonNull Completable	Completable.subscribeOn(@NonNull Scheduler scheduler)	Returns a Completable which subscribes the downstream subscriber on the specified scheduler, making sure the subscription side-effects happen on that specific thread of the Scheduler.
final @NonNull Completable	Flowable.switchMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps the upstream values into CompletableSources, subscribes to the newer one while disposing the subscription to the previous CompletableSource, thus keeping at most one active CompletableSource running.
final @NonNull Completable	Observable.switchMapCompletable(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps the items of the current Observable into CompletableSources, subscribes to the newer one while disposing the subscription to the previous CompletableSource, thus keeping at most one active CompletableSource running.
final @NonNull Completable	Flowable.switchMapCompletableDelayError(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps the upstream values into CompletableSources, subscribes to the newer one while disposing the subscription to the previous CompletableSource, thus keeping at most one active CompletableSource running and delaying any main or inner errors until all of them terminate.
final @NonNull Completable	Observable.switchMapCompletableDelayError(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper)	Maps the upstream values into CompletableSources, subscribes to the newer one while disposing the subscription to the previous CompletableSource, thus keeping at most one active CompletableSource running and delaying any main or inner errors until all of them terminate.
static @NonNull Completable	Completable.switchOnNext(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources)	Switches between CompletableSources emitted by the source Publisher whenever a new CompletableSource is emitted, disposing the previously running CompletableSource, exposing the setup as a Completable sequence.
static @NonNull Completable	Completable.switchOnNextDelayError(@NonNull org.reactivestreams.Publisher<@NonNull ? extends CompletableSource> sources)	Switches between CompletableSources emitted by the source Publisher whenever a new CompletableSource is emitted, disposing the previously running CompletableSource, exposing the setup as a Completable sequence and delaying all errors from all of them until all terminate.
final @NonNull Completable	Completable.takeUntil(@NonNull CompletableSource other)	Terminates the downstream if this or the other Completable terminates (wins the termination race) while disposing the connection to the losing source.
final @NonNull Completable	Completable.timeout(long timeout, @NonNull TimeUnit unit)	Returns a Completable that runs this Completable and emits a TimeoutException in case this Completable doesn't complete within the given time.
final @NonNull Completable	Completable.timeout(long timeout, @NonNull TimeUnit unit, @NonNull CompletableSource fallback)	Returns a Completable that runs this Completable and switches to the other CompletableSource in case this Completable doesn't complete within the given time.
final @NonNull Completable	Completable.timeout(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler)	Returns a Completable that runs this Completable and emits a TimeoutException in case this Completable doesn't complete within the given time while "waiting" on the specified Scheduler.
final @NonNull Completable	Completable.timeout(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull CompletableSource fallback)	Returns a Completable that runs this Completable and switches to the other CompletableSource in case this Completable doesn't complete within the given time while "waiting" on the specified Scheduler.
private @NonNull Completable	Completable.timeout0(long timeout, TimeUnit unit, Scheduler scheduler, CompletableSource fallback)	Returns a Completable that runs this Completable and optionally switches to the other CompletableSource in case this Completable doesn't complete within the given time while "waiting" on the specified Scheduler.
static @NonNull Completable	Completable.timer(long delay, @NonNull TimeUnit unit)	Returns a Completable instance that fires its onComplete event after the given delay elapsed.
static @NonNull Completable	Completable.timer(long delay, @NonNull TimeUnit unit, @NonNull Scheduler scheduler)	Returns a Completable instance that fires its onComplete event after the given delay elapsed by using the supplied Scheduler.
static @NonNull Completable	Completable.unsafeCreate(@NonNull CompletableSource onSubscribe)	Constructs a Completable instance by wrapping the given source callback without any safeguards; you should manage the lifecycle and response to downstream disposal.
final @NonNull Completable	Completable.unsubscribeOn(@NonNull Scheduler scheduler)	Returns a Completable which makes sure when an observer disposes the subscription, the dispose() method is called on the specified Scheduler.
static <@NonNull R> @NonNull Completable	Completable.using(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R, ? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup)	Returns a Completable instance which manages a resource along with a custom CompletableSource instance while the subscription is active.
static <@NonNull R> @NonNull Completable	Completable.using(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R, ? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup, boolean eager)	Returns a Completable instance which manages a resource along with a custom CompletableSource instance while the subscription is active and performs eager or lazy resource disposition.
static @NonNull Completable	Completable.wrap(@NonNull CompletableSource source)	Wraps the given CompletableSource into a Completable if not already Completable.

Methods in io.reactivex.rxjava3.core with parameters of type Completable

Modifier and Type	Method	Description
R	CompletableConverter.apply(@NonNull Completable upstream)	Applies a function to the upstream Completable and returns a converted value of type R.
@NonNull CompletableSource	CompletableTransformer.apply(@NonNull Completable upstream)	Applies a function to the upstream Completable and returns a CompletableSource.

Method parameters in io.reactivex.rxjava3.core with type arguments of type Completable

Modifier and Type	Method	Description
<S extends Scheduler & Disposable> S	Scheduler.when(@NonNull Function<Flowable<Flowable<Completable>>, Completable> combine)	Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.
<S extends Scheduler & Disposable> S	Scheduler.when(@NonNull Function<Flowable<Flowable<Completable>>, Completable> combine)	Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.

Uses of Completable in io.reactivex.rxjava3.internal.jdk8

Subclasses of Completable in io.reactivex.rxjava3.internal.jdk8

Modifier and Type	Class	Description
final class	CompletableFromCompletionStage<T>	Wrap a CompletionStage and signal its outcome.

Uses of Completable in io.reactivex.rxjava3.internal.operators.completable

Subclasses of Completable in io.reactivex.rxjava3.internal.operators.completable

Modifier and Type	Class	Description
final class	CompletableAmb
final class	CompletableAndThenCompletable
final class	CompletableCache	Consume the upstream source exactly once and cache its terminal event.
final class	CompletableConcat
final class	CompletableConcatArray
final class	CompletableConcatIterable
final class	CompletableCreate
final class	CompletableDefer
final class	CompletableDelay
final class	CompletableDetach	Breaks the references between the upstream and downstream when the Completable terminates.
final class	CompletableDisposeOn
final class	CompletableDoFinally	Execute an action after an onError, onComplete or a dispose event.
final class	CompletableDoOnEvent
final class	CompletableEmpty
final class	CompletableError
final class	CompletableErrorSupplier
final class	CompletableFromAction
final class	CompletableFromCallable
final class	CompletableFromObservable<T>
final class	CompletableFromPublisher<T>
final class	CompletableFromRunnable
final class	CompletableFromSingle<T>
final class	CompletableFromSupplier	Call a Supplier for each incoming CompletableObserver and signal completion or the thrown exception.
final class	CompletableFromUnsafeSource
final class	CompletableHide	Hides the identity of the upstream Completable and its Disposable sent through onSubscribe.
final class	CompletableLift
final class	CompletableMerge
final class	CompletableMergeArray
final class	CompletableMergeArrayDelayError
final class	CompletableMergeDelayErrorIterable
final class	CompletableMergeIterable
final class	CompletableNever
final class	CompletableObserveOn
final class	CompletableOnErrorComplete
final class	CompletablePeek
final class	CompletableResumeNext
final class	CompletableSubscribeOn
final class	CompletableTakeUntilCompletable	Terminates the sequence if either the main or the other Completable terminate.
final class	CompletableTimeout
final class	CompletableTimer	Signals an onComplete event after the specified delay.
final class	CompletableUsing<R>

Fields in io.reactivex.rxjava3.internal.operators.completable declared as Completable

Modifier and Type	Field	Description
static final Completable	CompletableEmpty.INSTANCE
static final Completable	CompletableNever.INSTANCE
(package private) final Completable	CompletableMaterialize.source
(package private) final Completable	CompletableTakeUntilCompletable.source

Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type Completable

Modifier	Constructor	Description
	CompletableMaterialize(Completable source)
	CompletableTakeUntilCompletable(Completable source, CompletableSource other)

Uses of Completable in io.reactivex.rxjava3.internal.operators.flowable

Subclasses of Completable in io.reactivex.rxjava3.internal.operators.flowable

Modifier and Type	Class	Description
final class	FlowableFlatMapCompletableCompletable<T>	Maps a sequence of values into CompletableSources and awaits their termination.
final class	FlowableIgnoreElementsCompletable<T>

Uses of Completable in io.reactivex.rxjava3.internal.operators.maybe

Subclasses of Completable in io.reactivex.rxjava3.internal.operators.maybe

Modifier and Type	Class	Description
final class	MaybeFlatMapCompletable<T>	Maps the success value of the source MaybeSource into a Completable.
final class	MaybeIgnoreElementCompletable<T>	Turns an onSuccess into an onComplete, onError and onComplete is relayed as is.

Uses of Completable in io.reactivex.rxjava3.internal.operators.mixed

Subclasses of Completable in io.reactivex.rxjava3.internal.operators.mixed

Modifier and Type	Class	Description
final class	FlowableConcatMapCompletable<T>	Maps the upstream items into CompletableSources and subscribes to them one after the other completes or terminates (in error-delaying mode).
final class	FlowableSwitchMapCompletable<T>	Maps the upstream values into CompletableSources, subscribes to the newer one while disposing the subscription to the previous CompletableSource, thus keeping at most one active CompletableSource running.
final class	FlowableSwitchMapCompletablePublisher<T>	Switch between subsequent CompletableSources emitted by a Publisher.
final class	ObservableConcatMapCompletable<T>	Maps the upstream items into CompletableSources and subscribes to them one after the other completes or terminates (in error-delaying mode).
final class	ObservableSwitchMapCompletable<T>	Maps the upstream values into CompletableSources, subscribes to the newer one while disposing the subscription to the previous CompletableSource, thus keeping at most one active CompletableSource running.

Uses of Completable in io.reactivex.rxjava3.internal.operators.observable

Subclasses of Completable in io.reactivex.rxjava3.internal.operators.observable

Modifier and Type	Class	Description
final class	ObservableFlatMapCompletableCompletable<T>	Maps a sequence of values into CompletableSources and awaits their termination.
final class	ObservableIgnoreElementsCompletable<T>

Uses of Completable in io.reactivex.rxjava3.internal.operators.single

Subclasses of Completable in io.reactivex.rxjava3.internal.operators.single

Modifier and Type	Class	Description
final class	SingleFlatMapCompletable<T>	Maps the success value of the source SingleSource into a Completable.

Uses of Completable in io.reactivex.rxjava3.internal.schedulers

Subclasses of Completable in io.reactivex.rxjava3.internal.schedulers

Modifier and Type	Class	Description
(package private) final class	SchedulerWhen.CreateWorkerFunction.WorkerCompletable

Classes in io.reactivex.rxjava3.internal.schedulers that implement interfaces with type arguments of type Completable

Modifier and Type	Class	Description
(package private) static final class	SchedulerWhen.CreateWorkerFunction

Fields in io.reactivex.rxjava3.internal.schedulers with type parameters of type Completable

Modifier and Type	Field	Description
private final FlowableProcessor<Flowable<Completable>>	SchedulerWhen.workerProcessor

Methods in io.reactivex.rxjava3.internal.schedulers that return Completable

Modifier and Type	Method	Description
Completable	SchedulerWhen.CreateWorkerFunction.apply(SchedulerWhen.ScheduledAction action)

Constructor parameters in io.reactivex.rxjava3.internal.schedulers with type arguments of type Completable

Modifier	Constructor	Description
	SchedulerWhen(Function<Flowable<Flowable<Completable>>, Completable> combine, Scheduler actualScheduler)
	SchedulerWhen(Function<Flowable<Flowable<Completable>>, Completable> combine, Scheduler actualScheduler)

Uses of Completable in io.reactivex.rxjava3.plugins

Fields in io.reactivex.rxjava3.plugins with type parameters of type Completable

Modifier and Type	Field	Description
(package private) static @Nullable Function<? super Completable, ? extends Completable>	RxJavaPlugins.onCompletableAssembly
(package private) static @Nullable Function<? super Completable, ? extends Completable>	RxJavaPlugins.onCompletableAssembly
(package private) static @Nullable BiFunction<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver>	RxJavaPlugins.onCompletableSubscribe

Methods in io.reactivex.rxjava3.plugins that return Completable

Modifier and Type	Method	Description
static @NonNull Completable	RxJavaPlugins.onAssembly(@NonNull Completable source)	Calls the associated hook function.

Methods in io.reactivex.rxjava3.plugins that return types with arguments of type Completable

Modifier and Type	Method	Description
static @Nullable Function<? super Completable, ? extends Completable>	RxJavaPlugins.getOnCompletableAssembly()	Returns the current hook function.
static @Nullable Function<? super Completable, ? extends Completable>	RxJavaPlugins.getOnCompletableAssembly()	Returns the current hook function.
static @Nullable BiFunction<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver>	RxJavaPlugins.getOnCompletableSubscribe()	Returns the current hook function.

Methods in io.reactivex.rxjava3.plugins with parameters of type Completable

Modifier and Type	Method	Description
static @NonNull Completable	RxJavaPlugins.onAssembly(@NonNull Completable source)	Calls the associated hook function.
static @NonNull CompletableObserver	RxJavaPlugins.onSubscribe(@NonNull Completable source, @NonNull CompletableObserver observer)	Calls the associated hook function.

Method parameters in io.reactivex.rxjava3.plugins with type arguments of type Completable

Modifier and Type	Method	Description
static void	RxJavaPlugins.setOnCompletableAssembly(@Nullable Function<? super Completable, ? extends Completable> onCompletableAssembly)	Sets the specific hook function.
static void	RxJavaPlugins.setOnCompletableAssembly(@Nullable Function<? super Completable, ? extends Completable> onCompletableAssembly)	Sets the specific hook function.
static void	RxJavaPlugins.setOnCompletableSubscribe(@Nullable BiFunction<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver> onCompletableSubscribe)	Sets the specific hook function.

Uses of Completable in io.reactivex.rxjava3.subjects

Subclasses of Completable in io.reactivex.rxjava3.subjects

Modifier and Type	Class	Description
final class	CompletableSubject	Represents a hot Completable-like source and consumer of events similar to Subjects.