Uses of Interface
io.reactivex.rxjava3.disposables.DisposableContainer
-
Packages that use DisposableContainer Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable
,Observable
,Single
,Maybe
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.disposables Default implementations forDisposable
-based resource management (Disposable
container types) and utility classes to constructDisposables
from callbacks and other types.io.reactivex.rxjava3.internal.disposables io.reactivex.rxjava3.internal.observers io.reactivex.rxjava3.internal.schedulers io.reactivex.rxjava3.internal.subscribers -
-
Uses of DisposableContainer in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type DisposableContainer Modifier and Type Method Description @NonNull Disposable
Completable. subscribe(@NonNull Action onComplete, @NonNull Consumer<? super java.lang.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.@NonNull Disposable
Flowable. subscribe(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super java.lang.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.@NonNull Disposable
Maybe. subscribe(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super java.lang.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.@NonNull Disposable
Observable. subscribe(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super java.lang.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.@NonNull Disposable
Single. subscribe(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super java.lang.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 DisposableContainer Modifier and Type Class Description class
CompositeDisposable
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 DisposableContainer Modifier and Type Class Description class
ListCompositeDisposable
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 DisposableContainer Modifier and Type Field Description (package private) java.util.concurrent.atomic.AtomicReference<DisposableContainer>
AbstractDisposableAutoRelease. composite
Constructors in io.reactivex.rxjava3.internal.observers with parameters of type DisposableContainer Constructor Description AbstractDisposableAutoRelease(DisposableContainer composite, Consumer<? super java.lang.Throwable> onError, Action onComplete)
DisposableAutoReleaseMultiObserver(DisposableContainer composite, Consumer<? super T> onSuccess, Consumer<? super java.lang.Throwable> onError, Action onComplete)
DisposableAutoReleaseObserver(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, Action onComplete)
-
Uses of DisposableContainer in io.reactivex.rxjava3.internal.schedulers
Fields in io.reactivex.rxjava3.internal.schedulers declared as DisposableContainer Modifier and Type Field Description (package private) DisposableContainer
ExecutorScheduler.ExecutorWorker.InterruptibleRunnable. tasks
Methods in io.reactivex.rxjava3.internal.schedulers with parameters of type DisposableContainer Modifier and Type Method Description @NonNull ScheduledRunnable
NewThreadWorker. scheduleActual(java.lang.Runnable run, long delayTime, @NonNull java.util.concurrent.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 DisposableContainer Constructor Description InterruptibleRunnable(java.lang.Runnable run, DisposableContainer tasks)
ScheduledRunnable(java.lang.Runnable actual, DisposableContainer parent)
Creates a ScheduledRunnable by wrapping the given action and setting up the optional parent.ScheduledRunnable(java.lang.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 DisposableContainer Modifier and Type Field Description (package private) java.util.concurrent.atomic.AtomicReference<DisposableContainer>
DisposableAutoReleaseSubscriber. composite
Constructors in io.reactivex.rxjava3.internal.subscribers with parameters of type DisposableContainer Constructor Description DisposableAutoReleaseSubscriber(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, Action onComplete)
-