Uses of Interface
io.reactivex.rxjava3.disposables.DisposableContainer
Packages that use DisposableContainer
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Default implementations for
Disposable
-based resource management
(Disposable
container types) and utility classes to construct
Disposables
from callbacks and other types.-
Uses of DisposableContainer in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type DisposableContainerModifier and TypeMethodDescriptionfinal @NonNull Disposable
Completable.subscribe
(@NonNull Action onComplete, @NonNull Consumer<? super Throwable> onError, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
CompletableObserver
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theCompletableObserver
is removed from the given composite.final @NonNull Disposable
Flowable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
Subscriber
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theSubscriber
is removed from the given container.final @NonNull Disposable
Maybe.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
MaybeObserver
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theMaybeObserver
is removed from the given composite.final @NonNull Disposable
Observable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
Observer
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theObserver
is removed from the given container.final @NonNull Disposable
Single.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
SingleObserver
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theSingleObserver
is removed from the given container. -
Uses of DisposableContainer in io.reactivex.rxjava3.disposables
Classes in io.reactivex.rxjava3.disposables that implement DisposableContainerModifier and TypeClassDescriptionfinal class
A disposable container that can hold onto multiple otherDisposable
s and offers O(1) time complexity forCompositeDisposable.add(Disposable)
,CompositeDisposable.remove(Disposable)
andCompositeDisposable.delete(Disposable)
operations. -
Uses of DisposableContainer in io.reactivex.rxjava3.internal.disposables
Classes in io.reactivex.rxjava3.internal.disposables that implement DisposableContainerModifier and TypeClassDescriptionfinal class
A disposable container that can hold onto multiple other disposables. -
Uses of DisposableContainer in io.reactivex.rxjava3.internal.observers
Fields in io.reactivex.rxjava3.internal.observers with type parameters of type DisposableContainerModifier and TypeFieldDescription(package private) final AtomicReference
<DisposableContainer> AbstractDisposableAutoRelease.composite
Constructors in io.reactivex.rxjava3.internal.observers with parameters of type DisposableContainerModifierConstructorDescription(package private)
AbstractDisposableAutoRelease
(DisposableContainer composite, Consumer<? super Throwable> onError, Action onComplete) DisposableAutoReleaseMultiObserver
(DisposableContainer composite, Consumer<? super T> onSuccess, Consumer<? super Throwable> onError, Action onComplete) DisposableAutoReleaseObserver
(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) -
Uses of DisposableContainer in io.reactivex.rxjava3.internal.schedulers
Fields in io.reactivex.rxjava3.internal.schedulers declared as DisposableContainerModifier and TypeFieldDescription(package private) final DisposableContainer
ExecutorScheduler.ExecutorWorker.InterruptibleRunnable.tasks
Methods in io.reactivex.rxjava3.internal.schedulers with parameters of type DisposableContainerModifier and TypeMethodDescriptionNewThreadWorker.scheduleActual
(Runnable run, long delayTime, @NonNull TimeUnit unit, @Nullable DisposableContainer parent) Wraps and returns the given runnable into a ScheduledRunnable and schedules it on the underlying ScheduledExecutorService.Constructors in io.reactivex.rxjava3.internal.schedulers with parameters of type DisposableContainerModifierConstructorDescription(package private)
InterruptibleRunnable
(Runnable run, DisposableContainer tasks) ScheduledRunnable
(Runnable actual, DisposableContainer parent) Creates a ScheduledRunnable by wrapping the given action and setting up the optional parent.ScheduledRunnable
(Runnable actual, DisposableContainer parent, boolean interruptOnCancel) Creates a ScheduledRunnable by wrapping the given action and setting up the optional parent. -
Uses of DisposableContainer in io.reactivex.rxjava3.internal.subscribers
Fields in io.reactivex.rxjava3.internal.subscribers with type parameters of type DisposableContainerModifier and TypeFieldDescription(package private) final AtomicReference
<DisposableContainer> DisposableAutoReleaseSubscriber.composite
Constructors in io.reactivex.rxjava3.internal.subscribers with parameters of type DisposableContainerModifierConstructorDescriptionDisposableAutoReleaseSubscriber
(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)