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 DisposableCompletable.subscribe(@NonNull Action onComplete, @NonNull Consumer<? super Throwable> onError, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposableCompletableObserver, adds it to the givenDisposableContainerand ensures, that if the upstream terminates or this particularDisposableis disposed, theCompletableObserveris removed from the given composite.final @NonNull DisposableFlowable.subscribe(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposableSubscriber, adds it to the givenDisposableContainerand ensures, that if the upstream terminates or this particularDisposableis disposed, theSubscriberis removed from the given container.final @NonNull DisposableMaybe.subscribe(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposableMaybeObserver, adds it to the givenDisposableContainerand ensures, that if the upstream terminates or this particularDisposableis disposed, theMaybeObserveris removed from the given composite.final @NonNull DisposableObservable.subscribe(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposableObserver, adds it to the givenDisposableContainerand ensures, that if the upstream terminates or this particularDisposableis disposed, theObserveris removed from the given container.final @NonNull DisposableSingle.subscribe(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposableSingleObserver, adds it to the givenDisposableContainerand ensures, that if the upstream terminates or this particularDisposableis disposed, theSingleObserveris removed from the given container. -
Uses of DisposableContainer in io.reactivex.rxjava3.disposables
Classes in io.reactivex.rxjava3.disposables that implement DisposableContainerModifier and TypeClassDescriptionfinal classA disposable container that can hold onto multiple otherDisposables 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 classA 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.compositeConstructors 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 DisposableContainerExecutorScheduler.ExecutorWorker.InterruptibleRunnable.tasksMethods 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.compositeConstructors in io.reactivex.rxjava3.internal.subscribers with parameters of type DisposableContainerModifierConstructorDescriptionDisposableAutoReleaseSubscriber(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)