Uses of Interface
io.reactivex.rxjava3.disposables.DisposableContainer
-
Packages that use DisposableContainer Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable,Observable,Single,MaybeandCompletable; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.disposables Default implementations forDisposable-based resource management (Disposablecontainer types) and utility classes to constructDisposablesfrom 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 DisposableCompletable. subscribe(@NonNull Action onComplete, @NonNull Consumer<? super java.lang.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.@NonNull DisposableFlowable. 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 aDisposableSubscriber, adds it to the givenDisposableContainerand ensures, that if the upstream terminates or this particularDisposableis disposed, theSubscriberis removed from the given container.@NonNull DisposableMaybe. 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 aDisposableMaybeObserver, adds it to the givenDisposableContainerand ensures, that if the upstream terminates or this particularDisposableis disposed, theMaybeObserveris removed from the given composite.@NonNull DisposableObservable. 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 aDisposableObserver, adds it to the givenDisposableContainerand ensures, that if the upstream terminates or this particularDisposableis disposed, theObserveris removed from the given container.@NonNull DisposableSingle. subscribe(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super java.lang.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 DisposableContainer Modifier and Type Class Description classCompositeDisposableA 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 DisposableContainer Modifier and Type Class Description classListCompositeDisposableA 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. compositeConstructors 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) DisposableContainerExecutorScheduler.ExecutorWorker.InterruptibleRunnable. tasksMethods in io.reactivex.rxjava3.internal.schedulers with parameters of type DisposableContainer Modifier and Type Method Description @NonNull ScheduledRunnableNewThreadWorker. 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. compositeConstructors 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)
-