Uses of Interface
io.reactivex.rxjava3.disposables.Disposable
Packages that use Disposable
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.Classes supporting the Flowable base reactive class:
ConnectableFlowable
and
GroupedFlowable
.Base interfaces and types for supporting operator-fusion.
Classes supporting the Observable base reactive class:
ConnectableObservable
and
GroupedObservable
.Default wrappers and implementations for observer-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestObserver
that allows unit testing
Observable
-, Single
-,
Maybe
- and Completable
-based flows.Classes and interfaces for writing advanced operators within and outside RxJava.
Contains notably the factory class of
Schedulers
providing methods for
retrieving the standard scheduler instances, the TestScheduler
for testing flows
with scheduling in a controlled manner and the class Timed
that can hold
a value and a timestamp associated with it.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.
Default wrappers and implementations for
Subscriber
-based consumer classes and interfaces,
including disposable (DisposableSubscriber
) and resource-tracking
(ResourceSubscriber
)
variants and the TestSubscriber
that allows unit testing
Flowable
-based flows.-
Uses of Disposable in io.reactivex.rxjava3.core
Classes in io.reactivex.rxjava3.core that implement DisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
static class
Represents an isolated, sequential worker of a parent Scheduler for executingRunnable
tasks on an underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system).Methods in io.reactivex.rxjava3.core with type parameters of type DisposableModifier and TypeMethodDescription<S extends Scheduler & Disposable>
SScheduler.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.Methods in io.reactivex.rxjava3.core that return DisposableModifier and TypeMethodDescriptionfinal @NonNull Disposable
Subscribes to the currentFlowable
and receives notifications for each element.final @NonNull Disposable
Subscribes to theObservableSource
and calls aConsumer
for each item of the currentObservable
on its emission thread.final @NonNull Disposable
Flowable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext) Subscribes to the currentFlowable
and receives notifications for each element until theonNext
Predicate returnsfalse
.final @NonNull Disposable
Flowable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to the currentFlowable
and receives notifications for each element and error events until theonNext
Predicate returnsfalse
.final @NonNull Disposable
Flowable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to the currentFlowable
and receives notifications for each element and the terminal events until theonNext
Predicate returnsfalse
.final @NonNull Disposable
Observable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext) Subscribes to theObservableSource
and calls aPredicate
for each item of the currentObservable
, on its emission thread, until the predicate returnsfalse
.final @NonNull Disposable
Observable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to theObservableSource
and calls aPredicate
for each item or aConsumer
with the error of the currentObservable
, on their original emission threads, until the predicate returnsfalse
.final @NonNull Disposable
Observable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to theObservableSource
and calls aPredicate
for each item, aConsumer
with the error or anAction
upon completion of the currentObservable
, on their original emission threads, until the predicate returnsfalse
.Schedules a Runnable for execution without any time delay.abstract @NonNull Disposable
Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time.Scheduler.scheduleDirect
(@NonNull Runnable run) Schedules the given task on this Scheduler without any time delay.Scheduler.scheduleDirect
(@NonNull Runnable run, long delay, @NonNull TimeUnit unit) Schedules the execution of the given task with the given time delay.Scheduler.Worker.schedulePeriodically
(@NonNull Runnable run, long initialDelay, long period, @NonNull TimeUnit unit) Schedules a periodic execution of the given task with the given initial time delay and repeat period.Scheduler.schedulePeriodicallyDirect
(@NonNull Runnable run, long initialDelay, long period, @NonNull TimeUnit unit) Schedules a periodic execution of the given task with the given initial time delay and repeat period.final @NonNull Disposable
Completable.subscribe()
Subscribes to thisCompletable
and returns aDisposable
which can be used to dispose the subscription.final @NonNull Disposable
final @NonNull Disposable
Subscribes to thisCompletable
and calls back either theonError
oronComplete
functions.final @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()
Subscribes to the currentFlowable
and ignoresonNext
andonComplete
emissions.final @NonNull Disposable
Subscribes to the currentFlowable
and provides a callback to handle the items it emits.final @NonNull Disposable
Flowable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to the currentFlowable
and provides callbacks to handle the items it emits and any error notification it issues.final @NonNull Disposable
Flowable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to the currentFlowable
and provides callbacks to handle the items it emits and any error or completion notification it issues.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()
Subscribes to aMaybe
and ignoresonSuccess
andonComplete
emissions.final @NonNull Disposable
Subscribes to aMaybe
and provides a callback to handle the items it emits.final @NonNull Disposable
Maybe.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError) Subscribes to aMaybe
and provides callbacks to handle the items it emits and any error notification it issues.final @NonNull Disposable
Maybe.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to aMaybe
and provides callbacks to handle the items it emits and any error or completion notification it issues.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()
Subscribes to the currentObservable
and ignoresonNext
andonComplete
emissions.final @NonNull Disposable
Subscribes to the currentObservable
and provides a callback to handle the items it emits.final @NonNull Disposable
Observable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to the currentObservable
and provides callbacks to handle the items it emits and any error notification it signals.final @NonNull Disposable
Observable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to the currentObservable
and provides callbacks to handle the items it emits and any error or completion notification it signals.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()
Subscribes to aSingle
but ignore its emission or notification.final @NonNull Disposable
Single.subscribe
(@NonNull BiConsumer<@Nullable ? super @NonNull T, @Nullable ? super Throwable> onCallback) Subscribes to aSingle
and provides a composite callback to handle the item it emits or any error notification it issues.final @NonNull Disposable
Subscribes to aSingle
and provides a callback to handle the item it emits.final @NonNull Disposable
Single.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError) Subscribes to aSingle
and provides callbacks to handle the item it emits or any error notification it issues.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.Methods in io.reactivex.rxjava3.core with parameters of type DisposableModifier and TypeMethodDescriptionvoid
CompletableObserver.onSubscribe
(@NonNull Disposable d) Called once by theCompletable
to set aDisposable
on this instance which then can be used to cancel the subscription at any time.void
MaybeObserver.onSubscribe
(@NonNull Disposable d) Provides theMaybeObserver
with the means of cancelling (disposing) the connection (channel) with theMaybe
in both synchronous (from withinonSubscribe(Disposable)
itself) and asynchronous manner.void
Observer.onSubscribe
(@NonNull Disposable d) Provides theObserver
with the means of cancelling (disposing) the connection (channel) with theObservable
in both synchronous (from withinObserver.onNext(Object)
) and asynchronous manner.void
SingleObserver.onSubscribe
(@NonNull Disposable d) Provides theSingleObserver
with the means of cancelling (disposing) the connection (channel) with the Single in both synchronous (from withinonSubscribe(Disposable)
itself) and asynchronous manner.void
CompletableEmitter.setDisposable
(@Nullable Disposable d) Sets a Disposable on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
FlowableEmitter.setDisposable
(@Nullable Disposable d) Sets a Disposable on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
MaybeEmitter.setDisposable
(@Nullable Disposable d) Sets aDisposable
on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
ObservableEmitter.setDisposable
(@Nullable Disposable d) Sets aDisposable
on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
SingleEmitter.setDisposable
(@Nullable Disposable d) Sets aDisposable
on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.Method parameters in io.reactivex.rxjava3.core with type arguments of type DisposableModifier and TypeMethodDescriptionfinal @NonNull Completable
Completable.doOnLifecycle
(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose) Calls the appropriateonXXX
method (shared between allCompletableObserver
s) 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 aCompletable
instance that calls the various callbacks upon the specific lifecycle events.Maybe.doOnLifecycle
(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose) Calls the appropriateonXXX
method (shared between allMaybeObserver
s) for the lifecycle events of the sequence (subscription, disposal).final @NonNull Observable
<T> Observable.doOnLifecycle
(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose) Calls the appropriateonXXX
method (shared between allObserver
s) for the lifecycle events of the sequence (subscription, disposal).Single.doOnLifecycle
(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose) Calls the appropriateonXXX
method (shared between allSingleObserver
s) for the lifecycle events of the sequence (subscription, disposal).final @NonNull Completable
Completable.doOnSubscribe
(@NonNull Consumer<? super Disposable> onSubscribe) Returns aCompletable
instance that calls the givenonSubscribe
callback with the disposable that the downstreamCompletableObserver
s receive upon subscription.Maybe.doOnSubscribe
(@NonNull Consumer<? super Disposable> onSubscribe) Calls the sharedConsumer
with theDisposable
sent through theonSubscribe
for eachMaybeObserver
that subscribes to the currentMaybe
.final @NonNull Observable
<T> Observable.doOnSubscribe
(@NonNull Consumer<? super Disposable> onSubscribe) Single.doOnSubscribe
(@NonNull Consumer<? super Disposable> onSubscribe) Calls the shared consumer with theDisposable
sent through theonSubscribe
for eachSingleObserver
that subscribes to the currentSingle
. -
Uses of Disposable in io.reactivex.rxjava3.disposables
Classes in io.reactivex.rxjava3.disposables that implement DisposableModifier and TypeClassDescription(package private) final class
A Disposable container that manages anAction
instance.(package private) final class
A disposable container that manages anAutoCloseable
instance.final 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.(package private) final class
A Disposable container that cancels aFuture
instance.(package private) class
Base class for Disposable containers that manage some other type that has to be run when the container is disposed.(package private) final class
A disposable container that manages aRunnable
instance.final class
A Disposable container that allows atomically updating/replacing the contained Disposable with another Disposable, disposing the old one when updating plus handling the disposition when the container itself is disposed.(package private) final class
A Disposable container that handles aSubscription
.Fields in io.reactivex.rxjava3.disposables with type parameters of type DisposableModifier and TypeFieldDescription(package private) final AtomicReference
<Disposable> SerialDisposable.resource
(package private) OpenHashSet
<Disposable> CompositeDisposable.resources
Methods in io.reactivex.rxjava3.disposables that return DisposableModifier and TypeMethodDescriptionstatic @NonNull Disposable
Disposable.disposed()
Returns a shared, disposedDisposable
instance.static @NonNull Disposable
Disposable.empty()
Returns a new, non-disposedDisposable
instance.static @NonNull Disposable
Disposable.fromAction
(@NonNull Action action) Construct aDisposable
by wrapping aAction
that is executed exactly once when theDisposable
is disposed.static @NonNull Disposable
Disposable.fromAutoCloseable
(@NonNull AutoCloseable autoCloseable) Construct aDisposable
by wrapping anAutoCloseable
that is closed exactly once when theDisposable
is disposed.static @NonNull Disposable
Disposable.fromFuture
(@NonNull Future<?> future) Construct aDisposable
by wrapping aFuture
that is cancelled exactly once when theDisposable
is disposed.static @NonNull Disposable
Disposable.fromFuture
(@NonNull Future<?> future, boolean allowInterrupt) Construct aDisposable
by wrapping aFuture
that is cancelled exactly once when theDisposable
is disposed.static @NonNull Disposable
Disposable.fromRunnable
(@NonNull Runnable run) Construct aDisposable
by wrapping aRunnable
that is executed exactly once when theDisposable
is disposed.static @NonNull Disposable
Disposable.fromSubscription
(@NonNull org.reactivestreams.Subscription subscription) Construct aDisposable
by wrapping aSubscription
that is cancelled exactly once when theDisposable
is disposed.SerialDisposable.get()
Returns the currently contained Disposable or null if this container is empty.Methods in io.reactivex.rxjava3.disposables with parameters of type DisposableModifier and TypeMethodDescriptionboolean
CompositeDisposable.add
(@NonNull Disposable disposable) Adds aDisposable
to this container or disposes it if the container has been disposed.boolean
DisposableContainer.add
(Disposable d) Adds a disposable to this container or disposes it if the container has been disposed.boolean
CompositeDisposable.addAll
(@NonNull Disposable... disposables) Atomically adds the given array ofDisposable
s to the container or disposes them all if the container has been disposed.boolean
CompositeDisposable.delete
(@NonNull Disposable disposable) Removes (but does not dispose) the givenDisposable
if it is part of this container.boolean
DisposableContainer.delete
(Disposable d) Removes but does not dispose the given disposable if it is part of this container.boolean
CompositeDisposable.remove
(@NonNull Disposable disposable) Removes and disposes the givenDisposable
if it is part of this container.boolean
DisposableContainer.remove
(Disposable d) Removes and disposes the given disposable if it is part of this container.boolean
SerialDisposable.replace
(@Nullable Disposable next) Atomically: set the next disposable on this container but don't dispose the previous one (if any) or dispose next if the container has been disposed.boolean
SerialDisposable.set
(@Nullable Disposable next) Atomically: set the next disposable on this container and dispose the previous one (if any) or dispose next if the container has been disposed.static @NonNull AutoCloseable
Disposable.toAutoCloseable
(@NonNull Disposable disposable) Construct anAutoCloseable
by wrapping aDisposable
that is disposed when the returnedAutoCloseable
is closed.Method parameters in io.reactivex.rxjava3.disposables with type arguments of type DisposableModifier and TypeMethodDescription(package private) void
CompositeDisposable.dispose
(@Nullable OpenHashSet<Disposable> set) Dispose the contents of theOpenHashSet
by suppressing non-fatalThrowable
s till the end.Constructors in io.reactivex.rxjava3.disposables with parameters of type DisposableModifierConstructorDescriptionCompositeDisposable
(@NonNull Disposable... disposables) Creates aCompositeDisposable
with the given array of initialDisposable
elements.SerialDisposable
(@Nullable Disposable initialDisposable) Constructs a SerialDisposable with the given initial Disposable instance.Constructor parameters in io.reactivex.rxjava3.disposables with type arguments of type DisposableModifierConstructorDescriptionCompositeDisposable
(@NonNull Iterable<? extends Disposable> disposables) -
Uses of Disposable in io.reactivex.rxjava3.flowables
Methods in io.reactivex.rxjava3.flowables that return DisposableModifier and TypeMethodDescriptionfinal @NonNull Disposable
ConnectableFlowable.connect()
Instructs theConnectableFlowable
to begin emitting the items from its underlyingFlowable
to itsSubscriber
s.Method parameters in io.reactivex.rxjava3.flowables with type arguments of type DisposableModifier and TypeMethodDescriptionConnectableFlowable.autoConnect
(int numberOfSubscribers, @NonNull Consumer<? super Disposable> connection) Returns aFlowable
that automatically connects (at most once) to thisConnectableFlowable
when the specified number ofSubscriber
s subscribe to it and calls the specified callback with theDisposable
associated with the established connection.abstract void
ConnectableFlowable.connect
(@NonNull Consumer<? super Disposable> connection) Instructs theConnectableFlowable
to begin emitting the items from its underlyingFlowable
to itsSubscriber
s. -
Uses of Disposable in io.reactivex.rxjava3.internal.disposables
Classes in io.reactivex.rxjava3.internal.disposables that implement DisposableModifier and TypeClassDescriptionfinal class
A composite disposable with a fixed number of slots.final class
A disposable container that wraps a Cancellable instance.enum
Utility methods for working with Disposables atomically.enum
Represents a stateless empty Disposable that reports being always empty and disposed.final class
A disposable container that can hold onto multiple other disposables.final class
A Disposable container that allows updating/replacing a Disposable atomically and with respect of disposing the container itself.Fields in io.reactivex.rxjava3.internal.disposables with type parameters of type DisposableModifier and TypeFieldDescription(package private) List
<Disposable> ListCompositeDisposable.resources
Methods in io.reactivex.rxjava3.internal.disposables that return DisposableModifier and TypeMethodDescriptionArrayCompositeDisposable.replaceResource
(int index, Disposable resource) Replaces the resource at the specified index and returns the old resource.Methods in io.reactivex.rxjava3.internal.disposables with parameters of type DisposableModifier and TypeMethodDescriptionboolean
ListCompositeDisposable.add
(Disposable d) boolean
ListCompositeDisposable.addAll
(Disposable... ds) boolean
ListCompositeDisposable.delete
(Disposable d) static boolean
DisposableHelper.isDisposed
(Disposable d) Checks if the given Disposable is the commonDisposableHelper.DISPOSED
enum value.boolean
ListCompositeDisposable.remove
(Disposable d) static boolean
DisposableHelper.replace
(AtomicReference<Disposable> field, Disposable d) Atomically replaces the Disposable in the field with the given new Disposable but does not dispose the old one.boolean
SequentialDisposable.replace
(Disposable next) Atomically: set the next disposable on this container but don't dispose the previous one (if any) or dispose next if the container has been disposed.ArrayCompositeDisposable.replaceResource
(int index, Disposable resource) Replaces the resource at the specified index and returns the old resource.static boolean
DisposableHelper.set
(AtomicReference<Disposable> field, Disposable d) Atomically sets the field and disposes the old contents.static boolean
DisposableHelper.setOnce
(AtomicReference<Disposable> field, Disposable d) Atomically sets the field to the given non-null Disposable and returns true or returns false if the field is non-null.boolean
ArrayCompositeDisposable.setResource
(int index, Disposable resource) Sets the resource at the specified index and disposes the old resource.static boolean
DisposableHelper.trySet
(AtomicReference<Disposable> field, Disposable d) Atomically tries to set the given Disposable on the field if it is null or disposes it if the field containsDisposableHelper.DISPOSED
.boolean
SequentialDisposable.update
(Disposable next) Atomically: set the next disposable on this container and dispose the previous one (if any) or dispose next if the container has been disposed.static boolean
DisposableHelper.validate
(Disposable current, Disposable next) Verifies that current is null, next is not null, otherwise signals errors to the RxJavaPlugins and returns false.Method parameters in io.reactivex.rxjava3.internal.disposables with type arguments of type DisposableModifier and TypeMethodDescriptionstatic boolean
DisposableHelper.dispose
(AtomicReference<Disposable> field) Atomically disposes the Disposable in the field if not already disposed.(package private) void
ListCompositeDisposable.dispose
(List<Disposable> set) static boolean
DisposableHelper.replace
(AtomicReference<Disposable> field, Disposable d) Atomically replaces the Disposable in the field with the given new Disposable but does not dispose the old one.static boolean
DisposableHelper.set
(AtomicReference<Disposable> field, Disposable d) Atomically sets the field and disposes the old contents.static boolean
DisposableHelper.setOnce
(AtomicReference<Disposable> field, Disposable d) Atomically sets the field to the given non-null Disposable and returns true or returns false if the field is non-null.static boolean
DisposableHelper.trySet
(AtomicReference<Disposable> field, Disposable d) Atomically tries to set the given Disposable on the field if it is null or disposes it if the field containsDisposableHelper.DISPOSED
.Constructors in io.reactivex.rxjava3.internal.disposables with parameters of type DisposableModifierConstructorDescriptionListCompositeDisposable
(Disposable... resources) SequentialDisposable
(Disposable initial) Construct a SequentialDisposable with the initial Disposable provided.Constructor parameters in io.reactivex.rxjava3.internal.disposables with type arguments of type Disposable -
Uses of Disposable in io.reactivex.rxjava3.internal.fuseable
Classes in io.reactivex.rxjava3.internal.fuseable that implement DisposableModifier and TypeClassDescriptionclass
Represents an empty, async-onlyQueueFuseable
instance.final class
Represents an empty, async-onlyQueueFuseable
instance that tracks and exposes a canceled/disposed state. -
Uses of Disposable in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement DisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.jdk8 declared as DisposableModifier and TypeFieldDescription(package private) Disposable
MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver.upstream
(package private) Disposable
MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver.upstream
(package private) Disposable
MaybeMapOptional.MapOptionalMaybeObserver.upstream
(package private) Disposable
ObservableCollectWithCollector.CollectorObserver.upstream
(package private) Disposable
ObservableCollectWithCollectorSingle.CollectorSingleObserver.upstream
(package private) Disposable
ObservableFlatMapStream.FlatMapStreamObserver.upstream
(package private) Disposable
SingleMapOptional.MapOptionalSingleObserver.upstream
Fields in io.reactivex.rxjava3.internal.jdk8 with type parameters of type DisposableModifier and TypeFieldDescription(package private) final AtomicReference
<Disposable> CompletionStageConsumer.upstream
(package private) final AtomicReference
<Disposable> ObservableStageObserver.upstream
Methods in io.reactivex.rxjava3.internal.jdk8 with parameters of type DisposableModifier and TypeMethodDescriptionvoid
CompletionStageConsumer.onSubscribe
(@NonNull Disposable d) void
MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver.onSubscribe
(@NonNull Disposable d) void
MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver.onSubscribe
(@NonNull Disposable d) void
MaybeMapOptional.MapOptionalMaybeObserver.onSubscribe
(Disposable d) void
ObservableCollectWithCollector.CollectorObserver.onSubscribe
(@NonNull Disposable d) void
ObservableCollectWithCollectorSingle.CollectorSingleObserver.onSubscribe
(@NonNull Disposable d) void
ObservableFlatMapStream.FlatMapStreamObserver.onSubscribe
(@NonNull Disposable d) final void
ObservableStageObserver.onSubscribe
(@NonNull Disposable d) void
SingleMapOptional.MapOptionalSingleObserver.onSubscribe
(Disposable d) -
Uses of Disposable in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement DisposableModifier and TypeClassDescription(package private) class
Wraps lambda callbacks and when the upstream terminates or the observer gets disposed, removes itself from aCompositeDisposable
.class
Base class for a fuseable intermediate observer.class
An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.class
An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.final class
class
final class
Blocks until the upstream terminates and dispatches the outcome to the actual observer.final class
Blocks until the upstream signals its first value or completes.final class
Blocks until the upstream signals its last value or completes.final class
final class
final class
class
Represents a fuseable container for a single value.class
A fuseable Observer that can generate 0 or 1 resulting value.final class
Wraps lambda callbacks and when the upstream terminates or this (Single | Maybe | Completable) observer gets disposed, removes itself from aCompositeDisposable
.final class
Wraps lambda callbacks and when the upstream terminates or this observer gets disposed, removes itself from aCompositeDisposable
.final class
final class
final class
final class
An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.final class
An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.final class
Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.final class
Fields in io.reactivex.rxjava3.internal.observers declared as DisposableModifier and TypeFieldDescriptionprotected Disposable
BasicFuseableObserver.upstream
The upstream subscription.(package private) Disposable
BlockingBaseObserver.upstream
(package private) Disposable
BlockingMultiObserver.upstream
protected Disposable
DeferredScalarObserver.upstream
The upstream disposable.(package private) Disposable
DisposableLambdaObserver.upstream
Fields in io.reactivex.rxjava3.internal.observers with type parameters of type DisposableModifier and TypeFieldDescription(package private) final Consumer
<? super Disposable> DisposableLambdaObserver.onSubscribe
(package private) final Consumer
<? super Disposable> LambdaObserver.onSubscribe
(package private) final AtomicReference
<Disposable> ResumeSingleObserver.parent
(package private) final AtomicReference
<Disposable> FutureMultiObserver.upstream
(package private) final AtomicReference
<Disposable> FutureObserver.upstream
Methods in io.reactivex.rxjava3.internal.observers with parameters of type DisposableModifier and TypeMethodDescriptionprotected final void
QueueDrainObserver.fastPathEmit
(U value, boolean delayError, Disposable dispose) protected final void
QueueDrainObserver.fastPathOrderedEmit
(U value, boolean delayError, Disposable disposable) Makes sure the fast-path emits in order.final void
AbstractDisposableAutoRelease.onSubscribe
(Disposable d) final void
BasicFuseableObserver.onSubscribe
(Disposable d) void
BiConsumerSingleObserver.onSubscribe
(Disposable d) final void
BlockingBaseObserver.onSubscribe
(Disposable d) void
BlockingDisposableMultiObserver.onSubscribe
(@NonNull Disposable d) void
BlockingMultiObserver.onSubscribe
(Disposable d) void
BlockingObserver.onSubscribe
(Disposable d) void
CallbackCompletableObserver.onSubscribe
(Disposable d) void
ConsumerSingleObserver.onSubscribe
(Disposable d) void
DeferredScalarObserver.onSubscribe
(Disposable d) void
DisposableLambdaObserver.onSubscribe
(Disposable d) void
EmptyCompletableObserver.onSubscribe
(Disposable d) void
ForEachWhileObserver.onSubscribe
(Disposable d) void
FutureMultiObserver.onSubscribe
(Disposable d) void
FutureObserver.onSubscribe
(Disposable d) void
InnerQueuedObserver.onSubscribe
(Disposable d) void
LambdaObserver.onSubscribe
(Disposable d) void
ResumeSingleObserver.onSubscribe
(Disposable d) void
SafeCompletableObserver.onSubscribe
(@NonNull Disposable d) void
SafeMaybeObserver.onSubscribe
(@NonNull Disposable d) void
SafeSingleObserver.onSubscribe
(@NonNull Disposable d) Constructor parameters in io.reactivex.rxjava3.internal.observers with type arguments of type DisposableModifierConstructorDescriptionDisposableLambdaObserver
(Observer<? super T> actual, Consumer<? super Disposable> onSubscribe, Action onDispose) ResumeSingleObserver
(AtomicReference<Disposable> parent, SingleObserver<? super T> downstream) -
Uses of Disposable in io.reactivex.rxjava3.internal.operators.completable
Classes in io.reactivex.rxjava3.internal.operators.completable that implement DisposableModifier and TypeClassDescription(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.completable declared as DisposableModifier and TypeFieldDescription(package private) Disposable
CompletableAmb.Amb.upstream
(package private) Disposable
CompletableDetach.DetachCompletableObserver.upstream
(package private) Disposable
CompletableDisposeOn.DisposeOnObserver.upstream
(package private) Disposable
CompletableDoFinally.DoFinallyObserver.upstream
(package private) Disposable
CompletableHide.HideCompletableObserver.upstream
(package private) Disposable
CompletableOnErrorReturn.OnErrorReturnMaybeObserver.upstream
(package private) Disposable
CompletablePeek.CompletableObserverImplementation.upstream
(package private) Disposable
CompletableUsing.UsingObserver.upstream
Fields in io.reactivex.rxjava3.internal.operators.completable with type parameters of type DisposableModifier and TypeFieldDescription(package private) final Consumer
<? super Disposable> CompletablePeek.onSubscribe
(package private) final AtomicReference
<Disposable> CompletableAndThenCompletable.NextObserver.parent
Methods in io.reactivex.rxjava3.internal.operators.completable with parameters of type DisposableModifier and TypeMethodDescriptionvoid
CompletableAmb.Amb.onSubscribe
(Disposable d) void
CompletableAndThenCompletable.NextObserver.onSubscribe
(Disposable d) void
CompletableAndThenCompletable.SourceObserver.onSubscribe
(Disposable d) void
CompletableCache.onSubscribe
(Disposable d) void
CompletableConcat.CompletableConcatSubscriber.ConcatInnerObserver.onSubscribe
(Disposable d) void
CompletableConcatArray.ConcatInnerObserver.onSubscribe
(Disposable d) void
CompletableConcatIterable.ConcatInnerObserver.onSubscribe
(Disposable d) void
CompletableDelay.Delay.onSubscribe
(Disposable d) void
CompletableDetach.DetachCompletableObserver.onSubscribe
(Disposable d) void
CompletableDisposeOn.DisposeOnObserver.onSubscribe
(Disposable d) void
CompletableDoFinally.DoFinallyObserver.onSubscribe
(Disposable d) void
CompletableDoOnEvent.DoOnEvent.onSubscribe
(Disposable d) void
CompletableFromObservable.CompletableFromObservableObserver.onSubscribe
(Disposable d) void
CompletableFromSingle.CompletableFromSingleObserver.onSubscribe
(Disposable d) void
CompletableHide.HideCompletableObserver.onSubscribe
(Disposable d) void
CompletableMerge.CompletableMergeSubscriber.MergeInnerObserver.onSubscribe
(Disposable d) void
CompletableMergeArray.InnerCompletableObserver.onSubscribe
(Disposable d) void
CompletableMergeArrayDelayError.MergeInnerCompletableObserver.onSubscribe
(Disposable d) void
CompletableMergeIterable.MergeCompletableObserver.onSubscribe
(Disposable d) void
CompletableObserveOn.ObserveOnCompletableObserver.onSubscribe
(Disposable d) void
CompletableOnErrorComplete.OnError.onSubscribe
(Disposable d) void
CompletableOnErrorReturn.OnErrorReturnMaybeObserver.onSubscribe
(Disposable d) void
CompletablePeek.CompletableObserverImplementation.onSubscribe
(Disposable d) void
CompletableResumeNext.ResumeNextObserver.onSubscribe
(Disposable d) void
CompletableSubscribeOn.SubscribeOnObserver.onSubscribe
(Disposable d) void
CompletableTakeUntilCompletable.TakeUntilMainObserver.onSubscribe
(Disposable d) void
CompletableTakeUntilCompletable.TakeUntilMainObserver.OtherObserver.onSubscribe
(Disposable d) void
CompletableTimeout.DisposeTask.DisposeObserver.onSubscribe
(Disposable d) void
CompletableTimeout.TimeOutObserver.onSubscribe
(Disposable d) void
CompletableToSingle.ToSingle.onSubscribe
(Disposable d) void
CompletableUsing.UsingObserver.onSubscribe
(Disposable d) void
CompletableCreate.Emitter.setDisposable
(Disposable d) (package private) void
CompletableTimer.TimerDisposable.setFuture
(Disposable d) Constructor parameters in io.reactivex.rxjava3.internal.operators.completable with type arguments of type DisposableModifierConstructorDescriptionCompletablePeek
(CompletableSource source, Consumer<? super Disposable> onSubscribe, Consumer<? super Throwable> onError, Action onComplete, Action onTerminate, Action onAfterTerminate, Action onDispose) (package private)
NextObserver
(AtomicReference<Disposable> parent, CompletableObserver downstream) -
Uses of Disposable in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement DisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
Subscriber of source, iterator for output.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
FlowableBufferBoundary.BufferCloseSubscriber<T,
C extends Collection<? super T>> (package private) static final class
FlowableBufferExactBoundary.BufferBoundarySubscriber<T,
U extends Collection<? super T>, B> (package private) static final class
FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,
U extends Collection<? super T>, B> (package private) static final class
FlowableBufferTimed.BufferExactBoundedSubscriber<T,
U extends Collection<? super T>> (package private) static final class
FlowableBufferTimed.BufferExactUnboundedSubscriber<T,
U extends Collection<? super T>> (package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) final class
(package private) final class
(package private) final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
A Subscription that manages the request and cancellation state of a child subscriber in thread-safe manner.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
FlowableToListSingle.ToListSubscriber<T,
U extends Collection<? super T>> (package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as DisposableModifier and TypeFieldDescription(package private) Disposable
FlowableBufferExactBoundary.BufferExactBoundarySubscriber.other
(package private) Disposable
FlowableBufferTimed.BufferExactBoundedSubscriber.timer
(package private) Disposable
FlowableRefCount.RefConnection.timer
(package private) Disposable
FlowableFromCompletable.FromCompletableObserver.upstream
(package private) Disposable
FlowableFromObservable.SubscriberObserver.upstream
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type DisposableModifier and TypeFieldDescription(package private) final Consumer
<? super Disposable> FlowableAutoConnect.connection
(package private) final AtomicReference
<Disposable> FlowableDebounce.DebounceSubscriber.debouncer
(package private) final AtomicReference
<Disposable> FlowableConcatWithMaybe.ConcatWithSubscriber.otherDisposable
(package private) final AtomicReference
<Disposable> FlowableConcatWithSingle.ConcatWithSubscriber.otherDisposable
(package private) final AtomicReference
<Disposable> FlowableInterval.IntervalSubscriber.resource
(package private) final AtomicReference
<Disposable> FlowableIntervalRange.IntervalRangeSubscriber.resource
(package private) final AtomicReference
<Disposable> FlowableBufferTimed.BufferExactUnboundedSubscriber.timer
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type DisposableModifier and TypeMethodDescriptionvoid
FlowableRefCount.RefConnection.accept
(Disposable t) void
FlowableReplay.MulticastFlowable.DisposableConsumer.accept
(Disposable r) (package private) void
FlowableBufferBoundary.BufferBoundarySubscriber.boundaryError
(Disposable subscriber, Throwable ex) void
FlowableConcatWithCompletable.ConcatWithSubscriber.onSubscribe
(Disposable d) void
FlowableConcatWithMaybe.ConcatWithSubscriber.onSubscribe
(Disposable d) void
FlowableConcatWithSingle.ConcatWithSubscriber.onSubscribe
(Disposable d) void
FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber.InnerConsumer.onSubscribe
(Disposable d) void
FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.InnerObserver.onSubscribe
(Disposable d) void
FlowableFlatMapMaybe.FlatMapMaybeSubscriber.InnerObserver.onSubscribe
(Disposable d) void
FlowableFlatMapSingle.FlatMapSingleSubscriber.InnerObserver.onSubscribe
(Disposable d) void
FlowableFromCompletable.FromCompletableObserver.onSubscribe
(Disposable d) void
FlowableFromObservable.SubscriberObserver.onSubscribe
(Disposable d) void
FlowableMergeWithCompletable.MergeWithSubscriber.OtherObserver.onSubscribe
(Disposable d) void
FlowableMergeWithMaybe.MergeWithObserver.OtherObserver.onSubscribe
(Disposable d) void
FlowableMergeWithSingle.MergeWithObserver.OtherObserver.onSubscribe
(Disposable d) final void
FlowableCreate.BaseEmitter.setDisposable
(Disposable d) void
FlowableCreate.SerializedEmitter.setDisposable
(Disposable d) void
FlowableDebounceTimed.DebounceEmitter.setResource
(Disposable d) void
FlowableInterval.IntervalSubscriber.setResource
(Disposable d) void
FlowableIntervalRange.IntervalRangeSubscriber.setResource
(Disposable d) void
FlowableTimer.TimerSubscriber.setResource
(Disposable d) Method parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type DisposableModifier and TypeMethodDescriptionvoid
FlowablePublish.connect
(Consumer<? super Disposable> connection) void
FlowableReplay.connect
(Consumer<? super Disposable> connection) Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type DisposableModifierConstructorDescriptionFlowableAutoConnect
(ConnectableFlowable<? extends T> source, int numberOfSubscribers, Consumer<? super Disposable> connection) -
Uses of Disposable in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement DisposableModifier and TypeClassDescription(package private) static final class
final class
MaybeObserver that delegates the onSuccess, onError and onComplete method calls to callbacks.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as DisposableModifier and TypeFieldDescription(package private) Disposable
MaybeUnsubscribeOn.UnsubscribeOnMaybeObserver.ds
(package private) Disposable
MaybeAmb.AmbMaybeObserver.upstream
(package private) Disposable
MaybeContains.ContainsMaybeObserver.upstream
(package private) Disposable
MaybeCount.CountMaybeObserver.upstream
(package private) Disposable
MaybeDelayOtherPublisher.DelayMaybeObserver.upstream
(package private) Disposable
MaybeDematerialize.DematerializeObserver.upstream
(package private) Disposable
MaybeDetach.DetachMaybeObserver.upstream
(package private) Disposable
MaybeDoAfterSuccess.DoAfterObserver.upstream
(package private) Disposable
MaybeDoFinally.DoFinallyObserver.upstream
(package private) Disposable
MaybeDoOnEvent.DoOnEventMaybeObserver.upstream
(package private) Disposable
MaybeDoOnLifecycle.MaybeLifecycleObserver.upstream
(package private) Disposable
MaybeFilter.FilterMaybeObserver.upstream
(package private) Disposable
MaybeFilterSingle.FilterMaybeObserver.upstream
(package private) Disposable
MaybeFlatMapIterableFlowable.FlatMapIterableObserver.upstream
(package private) Disposable
MaybeFlatMapIterableObservable.FlatMapIterableObserver.upstream
(package private) Disposable
MaybeFlatMapNotification.FlatMapMaybeObserver.upstream
(package private) Disposable
MaybeFlatten.FlatMapMaybeObserver.upstream
(package private) Disposable
MaybeFromCompletable.FromCompletableObserver.upstream
(package private) Disposable
MaybeFromSingle.FromSingleObserver.upstream
(package private) Disposable
MaybeHide.HideMaybeObserver.upstream
(package private) Disposable
MaybeIgnoreElement.IgnoreMaybeObserver.upstream
(package private) Disposable
MaybeIgnoreElementCompletable.IgnoreMaybeObserver.upstream
(package private) Disposable
MaybeIsEmpty.IsEmptyMaybeObserver.upstream
(package private) Disposable
MaybeIsEmptySingle.IsEmptyMaybeObserver.upstream
(package private) Disposable
MaybeMap.MapMaybeObserver.upstream
(package private) Disposable
MaybeOnErrorComplete.OnErrorCompleteMultiObserver.upstream
(package private) Disposable
MaybeOnErrorReturn.OnErrorReturnMaybeObserver.upstream
(package private) Disposable
MaybePeek.MaybePeekObserver.upstream
(package private) Disposable
MaybeTimeInterval.TimeIntervalMaybeObserver.upstream
(package private) Disposable
MaybeToFlowable.MaybeToFlowableSubscriber.upstream
(package private) Disposable
MaybeToObservable.MaybeToObservableObserver.upstream
(package private) Disposable
MaybeToSingle.ToSingleMaybeSubscriber.upstream
(package private) Disposable
MaybeUsing.UsingObserver.upstream
Fields in io.reactivex.rxjava3.internal.operators.maybe with type parameters of type DisposableModifier and TypeFieldDescription(package private) final Consumer
<? super Disposable> MaybeDoOnLifecycle.MaybeLifecycleObserver.onSubscribe
(package private) final Consumer
<? super Disposable> MaybeDoOnLifecycle.onSubscribe
(package private) final Consumer
<? super Disposable> MaybePeek.onSubscribeCall
(package private) final AtomicReference
<Disposable> MaybeDelayWithCompletable.DelayWithMainObserver.parent
(package private) final AtomicReference
<Disposable> MaybeFlatMapSingle.FlatMapSingleObserver.parent
(package private) final AtomicReference
<Disposable> MaybeSwitchIfEmpty.SwitchIfEmptyMaybeObserver.OtherMaybeObserver.parent
(package private) final AtomicReference
<Disposable> MaybeSwitchIfEmptySingle.SwitchIfEmptyMaybeObserver.OtherSingleObserver.parent
(package private) final AtomicReference
<Disposable> MaybeOnErrorNext.OnErrorNextMaybeObserver.NextMaybeObserver.upstream
Methods in io.reactivex.rxjava3.internal.operators.maybe with parameters of type DisposableModifier and TypeMethodDescriptionvoid
MaybeAmb.AmbMaybeObserver.onSubscribe
(Disposable d) void
MaybeCache.onSubscribe
(Disposable d) void
MaybeCallbackObserver.onSubscribe
(Disposable d) void
MaybeConcatArray.ConcatMaybeObserver.onSubscribe
(Disposable d) void
MaybeConcatArrayDelayError.ConcatMaybeObserver.onSubscribe
(Disposable d) void
MaybeConcatIterable.ConcatMaybeObserver.onSubscribe
(Disposable d) void
MaybeContains.ContainsMaybeObserver.onSubscribe
(Disposable d) void
MaybeCount.CountMaybeObserver.onSubscribe
(Disposable d) void
MaybeDelay.DelayMaybeObserver.onSubscribe
(Disposable d) void
MaybeDelayOtherPublisher.DelayMaybeObserver.onSubscribe
(Disposable d) void
MaybeDelaySubscriptionOtherPublisher.DelayMaybeObserver.onSubscribe
(Disposable d) void
MaybeDelayWithCompletable.DelayWithMainObserver.onSubscribe
(Disposable d) void
MaybeDelayWithCompletable.OtherObserver.onSubscribe
(Disposable d) void
MaybeDematerialize.DematerializeObserver.onSubscribe
(Disposable d) void
MaybeDetach.DetachMaybeObserver.onSubscribe
(Disposable d) void
MaybeDoAfterSuccess.DoAfterObserver.onSubscribe
(Disposable d) void
MaybeDoFinally.DoFinallyObserver.onSubscribe
(Disposable d) void
MaybeDoOnEvent.DoOnEventMaybeObserver.onSubscribe
(Disposable d) void
MaybeDoOnLifecycle.MaybeLifecycleObserver.onSubscribe
(@NonNull Disposable d) void
MaybeDoOnTerminate.DoOnTerminate.onSubscribe
(Disposable d) void
MaybeEqualSingle.EqualObserver.onSubscribe
(Disposable d) void
MaybeFilter.FilterMaybeObserver.onSubscribe
(Disposable d) void
MaybeFilterSingle.FilterMaybeObserver.onSubscribe
(Disposable d) void
MaybeFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver.onSubscribe
(Disposable d) void
MaybeFlatMapBiSelector.FlatMapBiMainObserver.onSubscribe
(Disposable d) void
MaybeFlatMapCompletable.FlatMapCompletableObserver.onSubscribe
(Disposable d) void
MaybeFlatMapIterableFlowable.FlatMapIterableObserver.onSubscribe
(Disposable d) void
MaybeFlatMapIterableObservable.FlatMapIterableObserver.onSubscribe
(Disposable d) void
MaybeFlatMapNotification.FlatMapMaybeObserver.InnerObserver.onSubscribe
(Disposable d) void
MaybeFlatMapNotification.FlatMapMaybeObserver.onSubscribe
(Disposable d) void
MaybeFlatMapSingle.FlatMapMaybeObserver.onSubscribe
(Disposable d) void
MaybeFlatMapSingle.FlatMapSingleObserver.onSubscribe
(Disposable d) void
MaybeFlatten.FlatMapMaybeObserver.InnerObserver.onSubscribe
(Disposable d) void
MaybeFlatten.FlatMapMaybeObserver.onSubscribe
(Disposable d) void
MaybeFromCompletable.FromCompletableObserver.onSubscribe
(Disposable d) void
MaybeFromSingle.FromSingleObserver.onSubscribe
(Disposable d) void
MaybeHide.HideMaybeObserver.onSubscribe
(Disposable d) void
MaybeIgnoreElement.IgnoreMaybeObserver.onSubscribe
(Disposable d) void
MaybeIgnoreElementCompletable.IgnoreMaybeObserver.onSubscribe
(Disposable d) void
MaybeIsEmpty.IsEmptyMaybeObserver.onSubscribe
(Disposable d) void
MaybeIsEmptySingle.IsEmptyMaybeObserver.onSubscribe
(Disposable d) void
MaybeMap.MapMaybeObserver.onSubscribe
(Disposable d) void
MaybeMergeArray.MergeMaybeObserver.onSubscribe
(Disposable d) void
MaybeObserveOn.ObserveOnMaybeObserver.onSubscribe
(Disposable d) void
MaybeOnErrorComplete.OnErrorCompleteMultiObserver.onSubscribe
(Disposable d) void
MaybeOnErrorNext.OnErrorNextMaybeObserver.NextMaybeObserver.onSubscribe
(Disposable d) void
MaybeOnErrorNext.OnErrorNextMaybeObserver.onSubscribe
(Disposable d) void
MaybeOnErrorReturn.OnErrorReturnMaybeObserver.onSubscribe
(Disposable d) void
MaybePeek.MaybePeekObserver.onSubscribe
(Disposable d) void
MaybeSubscribeOn.SubscribeOnMaybeObserver.onSubscribe
(Disposable d) void
MaybeSwitchIfEmpty.SwitchIfEmptyMaybeObserver.onSubscribe
(Disposable d) void
MaybeSwitchIfEmpty.SwitchIfEmptyMaybeObserver.OtherMaybeObserver.onSubscribe
(Disposable d) void
MaybeSwitchIfEmptySingle.SwitchIfEmptyMaybeObserver.onSubscribe
(Disposable d) void
MaybeSwitchIfEmptySingle.SwitchIfEmptyMaybeObserver.OtherSingleObserver.onSubscribe
(Disposable d) void
MaybeTakeUntilMaybe.TakeUntilMainMaybeObserver.onSubscribe
(Disposable d) void
MaybeTakeUntilMaybe.TakeUntilMainMaybeObserver.TakeUntilOtherMaybeObserver.onSubscribe
(Disposable d) void
MaybeTakeUntilPublisher.TakeUntilMainMaybeObserver.onSubscribe
(Disposable d) void
MaybeTimeInterval.TimeIntervalMaybeObserver.onSubscribe
(@NonNull Disposable d) void
MaybeTimeoutMaybe.TimeoutFallbackMaybeObserver.onSubscribe
(Disposable d) void
MaybeTimeoutMaybe.TimeoutMainMaybeObserver.onSubscribe
(Disposable d) void
MaybeTimeoutMaybe.TimeoutOtherMaybeObserver.onSubscribe
(Disposable d) void
MaybeTimeoutPublisher.TimeoutFallbackMaybeObserver.onSubscribe
(Disposable d) void
MaybeTimeoutPublisher.TimeoutMainMaybeObserver.onSubscribe
(Disposable d) void
MaybeToFlowable.MaybeToFlowableSubscriber.onSubscribe
(Disposable d) void
MaybeToObservable.MaybeToObservableObserver.onSubscribe
(Disposable d) void
MaybeToSingle.ToSingleMaybeSubscriber.onSubscribe
(Disposable d) void
MaybeUnsubscribeOn.UnsubscribeOnMaybeObserver.onSubscribe
(Disposable d) void
MaybeUsing.UsingObserver.onSubscribe
(Disposable d) void
MaybeZipArray.ZipMaybeObserver.onSubscribe
(Disposable d) void
MaybeCreate.Emitter.setDisposable
(Disposable d) (package private) void
MaybeTimer.TimerDisposable.setFuture
(Disposable d) Constructor parameters in io.reactivex.rxjava3.internal.operators.maybe with type arguments of type DisposableModifierConstructorDescription(package private)
DelayWithMainObserver
(AtomicReference<Disposable> parent, MaybeObserver<? super T> downstream) (package private)
FlatMapSingleObserver
(AtomicReference<Disposable> parent, MaybeObserver<? super R> downstream) MaybeDoOnLifecycle
(Maybe<T> upstream, Consumer<? super Disposable> onSubscribe, Action onDispose) (package private)
MaybeLifecycleObserver
(MaybeObserver<? super T> downstream, Consumer<? super Disposable> onSubscribe, Action onDispose) MaybePeek
(MaybeSource<T> source, Consumer<? super Disposable> onSubscribeCall, Consumer<? super T> onSuccessCall, Consumer<? super Throwable> onErrorCall, Action onCompleteCall, Action onAfterTerminate, Action onDispose) (package private)
NextMaybeObserver
(MaybeObserver<? super T> actual, AtomicReference<Disposable> d) (package private)
OtherMaybeObserver
(MaybeObserver<? super T> actual, AtomicReference<Disposable> parent) (package private)
OtherSingleObserver
(SingleObserver<? super T> actual, AtomicReference<Disposable> parent) -
Uses of Disposable in io.reactivex.rxjava3.internal.operators.mixed
Classes in io.reactivex.rxjava3.internal.operators.mixed that implement DisposableModifier and TypeClassDescription(package private) static final class
class
Base class for implementing concatMapX main observers.(package private) static final class
(package private) static final class
final class
A consumer that implements the consumer types of Maybe, Single and Completable and turns their signals into Notifications for a SingleObserver.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.mixed declared as DisposableModifier and TypeFieldDescription(package private) Disposable
CompletableAndThenPublisher.AndThenPublisherSubscriber.upstream
(package private) Disposable
ConcatMapXMainObserver.upstream
(package private) Disposable
MaterializeSingleObserver.upstream
(package private) Disposable
MaybeFlatMapPublisher.FlatMapPublisherSubscriber.upstream
(package private) Disposable
ObservableSwitchMapCompletable.SwitchMapCompletableObserver.upstream
(package private) Disposable
ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.upstream
(package private) Disposable
ObservableSwitchMapSingle.SwitchMapSingleMainObserver.upstream
Methods in io.reactivex.rxjava3.internal.operators.mixed with parameters of type DisposableModifier and TypeMethodDescriptionvoid
CompletableAndThenObservable.AndThenObservableObserver.onSubscribe
(Disposable d) void
CompletableAndThenPublisher.AndThenPublisherSubscriber.onSubscribe
(Disposable d) final void
ConcatMapXMainObserver.onSubscribe
(Disposable d) void
FlowableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver.onSubscribe
(Disposable d) void
FlowableConcatMapMaybe.ConcatMapMaybeSubscriber.ConcatMapMaybeObserver.onSubscribe
(Disposable d) void
FlowableConcatMapSingle.ConcatMapSingleSubscriber.ConcatMapSingleObserver.onSubscribe
(Disposable d) void
FlowableSwitchMapCompletable.SwitchMapCompletableObserver.SwitchMapInnerObserver.onSubscribe
(Disposable d) void
FlowableSwitchMapMaybe.SwitchMapMaybeSubscriber.SwitchMapMaybeObserver.onSubscribe
(Disposable d) void
FlowableSwitchMapSingle.SwitchMapSingleSubscriber.SwitchMapSingleObserver.onSubscribe
(Disposable d) void
MaterializeSingleObserver.onSubscribe
(Disposable d) void
MaybeFlatMapObservable.FlatMapObserver.onSubscribe
(Disposable d) void
MaybeFlatMapPublisher.FlatMapPublisherSubscriber.onSubscribe
(Disposable d) void
ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver.onSubscribe
(Disposable d) void
ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.ConcatMapMaybeObserver.onSubscribe
(Disposable d) void
ObservableConcatMapSingle.ConcatMapSingleMainObserver.ConcatMapSingleObserver.onSubscribe
(Disposable d) void
ObservableSwitchMapCompletable.SwitchMapCompletableObserver.onSubscribe
(Disposable d) void
ObservableSwitchMapCompletable.SwitchMapCompletableObserver.SwitchMapInnerObserver.onSubscribe
(Disposable d) void
ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.onSubscribe
(Disposable d) void
ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.SwitchMapMaybeObserver.onSubscribe
(Disposable d) void
ObservableSwitchMapSingle.SwitchMapSingleMainObserver.onSubscribe
(Disposable d) void
ObservableSwitchMapSingle.SwitchMapSingleMainObserver.SwitchMapSingleObserver.onSubscribe
(Disposable d) void
SingleFlatMapObservable.FlatMapObserver.onSubscribe
(Disposable d) -
Uses of Disposable in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement DisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
ObservableBuffer.BufferExactObserver<T,
U extends Collection<? super T>> (package private) static final class
ObservableBuffer.BufferSkipObserver<T,
U extends Collection<? super T>> (package private) static final class
ObservableBufferBoundary.BufferBoundaryObserver<T,
C extends Collection<? super T>, Open, Close> (package private) static final class
(package private) static final class
ObservableBufferBoundary.BufferCloseObserver<T,
C extends Collection<? super T>> (package private) static final class
ObservableBufferExactBoundary.BufferBoundaryObserver<T,
U extends Collection<? super T>, B> (package private) static final class
ObservableBufferExactBoundary.BufferExactBoundaryObserver<T,
U extends Collection<? super T>, B> (package private) static final class
ObservableBufferTimed.BufferExactBoundedObserver<T,
U extends Collection<? super T>> (package private) static final class
ObservableBufferTimed.BufferExactUnboundedObserver<T,
U extends Collection<? super T>> (package private) static final class
ObservableBufferTimed.BufferSkipBoundedObserver<T,
U extends Collection<? super T>> (package private) static final class
Hosts the downstream consumer and its current requested and replay states.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
ObservableGroupJoin.GroupJoinDisposable<TLeft,
TRight, TLeftEnd, TRightEnd, R> (package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
ObservableJoin.JoinDisposable<TLeft,
TRight, TLeftEnd, TRightEnd, R> (package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
Intercepts the dispose signal from the downstream and removes itself from the connection's observers array at most once.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
A Disposable that manages the disposed state of a child Observer in thread-safe manner.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static class
static final class
Represents a Disposable that signals one onNext followed by an onComplete.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
ObservableToList.ToListObserver<T,
U extends Collection<? super T>> (package private) static final class
ObservableToListSingle.ToListObserver<T,
U extends Collection<? super T>> (package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as DisposableModifier and TypeFieldDescription(package private) Disposable
ObservableBufferExactBoundary.BufferExactBoundaryObserver.other
(package private) Disposable
ObservableBufferTimed.BufferExactBoundedObserver.timer
(package private) Disposable
ObservableRefCount.RefConnection.timer
(package private) Disposable
ObservableAll.AllObserver.upstream
(package private) Disposable
ObservableAllSingle.AllObserver.upstream
(package private) Disposable
ObservableAny.AnyObserver.upstream
(package private) Disposable
ObservableAnySingle.AnyObserver.upstream
(package private) Disposable
ObservableBuffer.BufferExactObserver.upstream
(package private) Disposable
ObservableBuffer.BufferSkipObserver.upstream
(package private) Disposable
ObservableBufferExactBoundary.BufferExactBoundaryObserver.upstream
(package private) Disposable
ObservableBufferTimed.BufferExactBoundedObserver.upstream
(package private) Disposable
ObservableBufferTimed.BufferExactUnboundedObserver.upstream
(package private) Disposable
ObservableBufferTimed.BufferSkipBoundedObserver.upstream
(package private) Disposable
ObservableCollect.CollectObserver.upstream
(package private) Disposable
ObservableCollectSingle.CollectObserver.upstream
(package private) Disposable
ObservableConcatMap.ConcatMapDelayErrorObserver.upstream
(package private) Disposable
ObservableConcatMap.SourceObserver.upstream
(package private) Disposable
ObservableConcatMapEager.ConcatMapEagerMainObserver.upstream
(package private) Disposable
ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.upstream
(package private) Disposable
ObservableConcatMapScheduler.ConcatMapObserver.upstream
(package private) Disposable
ObservableCount.CountObserver.upstream
(package private) Disposable
ObservableCountSingle.CountObserver.upstream
(package private) Disposable
ObservableDebounce.DebounceObserver.upstream
(package private) Disposable
ObservableDebounceTimed.DebounceTimedObserver.upstream
(package private) Disposable
ObservableDelay.DelayObserver.upstream
(package private) Disposable
ObservableDematerialize.DematerializeObserver.upstream
(package private) Disposable
ObservableDetach.DetachObserver.upstream
(package private) Disposable
ObservableDoFinally.DoFinallyObserver.upstream
(package private) Disposable
ObservableDoOnEach.DoOnEachObserver.upstream
(package private) Disposable
ObservableElementAt.ElementAtObserver.upstream
(package private) Disposable
ObservableElementAtMaybe.ElementAtObserver.upstream
(package private) Disposable
ObservableElementAtSingle.ElementAtObserver.upstream
(package private) Disposable
ObservableFlatMap.MergeObserver.upstream
(package private) Disposable
ObservableFlatMapCompletable.FlatMapCompletableMainObserver.upstream
(package private) Disposable
ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.upstream
(package private) Disposable
ObservableFlatMapMaybe.FlatMapMaybeObserver.upstream
(package private) Disposable
ObservableFlatMapSingle.FlatMapSingleObserver.upstream
(package private) Disposable
ObservableFlattenIterable.FlattenIterableObserver.upstream
(package private) Disposable
ObservableFromCompletable.FromCompletableObserver.upstream
(package private) Disposable
ObservableGroupBy.GroupByObserver.upstream
(package private) Disposable
ObservableHide.HideDisposable.upstream
(package private) Disposable
ObservableIgnoreElements.IgnoreObservable.upstream
(package private) Disposable
ObservableIgnoreElementsCompletable.IgnoreObservable.upstream
(package private) Disposable
ObservableLastMaybe.LastObserver.upstream
(package private) Disposable
ObservableLastSingle.LastObserver.upstream
(package private) Disposable
ObservableMapNotification.MapNotificationObserver.upstream
(package private) Disposable
ObservableMaterialize.MaterializeObserver.upstream
(package private) Disposable
ObservableObserveOn.ObserveOnObserver.upstream
(package private) Disposable
ObservableOnErrorComplete.OnErrorCompleteObserver.upstream
(package private) Disposable
ObservableOnErrorReturn.OnErrorReturnObserver.upstream
(package private) Disposable
ObservablePublishSelector.TargetObserver.upstream
(package private) Disposable
ObservableReduceMaybe.ReduceObserver.upstream
(package private) Disposable
ObservableReduceSeedSingle.ReduceSeedObserver.upstream
(package private) Disposable
ObservableRefCount.RefCountObserver.upstream
(package private) Disposable
ObservableSampleTimed.SampleTimedObserver.upstream
(package private) Disposable
ObservableSampleWithObservable.SampleMainObserver.upstream
(package private) Disposable
ObservableScan.ScanObserver.upstream
(package private) Disposable
ObservableScanSeed.ScanSeedObserver.upstream
(package private) Disposable
ObservableSingleMaybe.SingleElementObserver.upstream
(package private) Disposable
ObservableSingleSingle.SingleElementObserver.upstream
(package private) Disposable
ObservableSkip.SkipObserver.upstream
(package private) Disposable
ObservableSkipLast.SkipLastObserver.upstream
(package private) Disposable
ObservableSkipLastTimed.SkipLastTimedObserver.upstream
(package private) Disposable
ObservableSkipUntil.SkipUntil.upstream
(package private) Disposable
ObservableSkipUntil.SkipUntilObserver.upstream
(package private) Disposable
ObservableSkipWhile.SkipWhileObserver.upstream
(package private) Disposable
ObservableSwitchMap.SwitchMapObserver.upstream
(package private) Disposable
ObservableTake.TakeObserver.upstream
(package private) Disposable
ObservableTakeLast.TakeLastObserver.upstream
(package private) Disposable
ObservableTakeLastOne.TakeLastOneObserver.upstream
(package private) Disposable
ObservableTakeLastTimed.TakeLastTimedObserver.upstream
(package private) Disposable
ObservableTakeUntilPredicate.TakeUntilPredicateObserver.upstream
(package private) Disposable
ObservableTakeWhile.TakeWhileObserver.upstream
(package private) Disposable
ObservableThrottleFirstTimed.DebounceTimedObserver.upstream
(package private) Disposable
ObservableThrottleLatest.ThrottleLatestObserver.upstream
(package private) Disposable
ObservableTimeInterval.TimeIntervalObserver.upstream
(package private) Disposable
ObservableToList.ToListObserver.upstream
(package private) Disposable
ObservableToListSingle.ToListObserver.upstream
(package private) Disposable
ObservableUnsubscribeOn.UnsubscribeObserver.upstream
(package private) Disposable
ObservableUsing.UsingObserver.upstream
(package private) Disposable
ObservableWindow.WindowExactObserver.upstream
(package private) Disposable
ObservableWindow.WindowSkipObserver.upstream
(package private) Disposable
ObservableWindowBoundarySelector.WindowBoundaryMainObserver.upstream
(package private) Disposable
ObservableWindowTimed.AbstractWindowObserver.upstream
(package private) Disposable
ObservableZipIterable.ZipIterableObserver.upstream
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type DisposableModifier and TypeFieldDescription(package private) final AtomicReference
<Disposable> ObservableTimeoutTimed.FallbackObserver.arbiter
(package private) final Consumer
<? super Disposable> ObservableAutoConnect.connection
(package private) final AtomicReference
<Disposable> ObservableDebounce.DebounceObserver.debouncer
(package private) final AtomicReference
<Disposable> ObservableMergeWithCompletable.MergeWithObserver.mainDisposable
(package private) final AtomicReference
<Disposable> ObservableMergeWithMaybe.MergeWithObserver.mainDisposable
(package private) final AtomicReference
<Disposable> ObservableMergeWithSingle.MergeWithObserver.mainDisposable
private final Consumer
<? super Disposable> ObservableDoOnLifecycle.onSubscribe
(package private) final AtomicReference
<Disposable> ObservableSampleWithObservable.SampleMainObserver.other
(package private) final AtomicReference
<Disposable> ObservableWithLatestFrom.WithLatestFromObserver.other
(package private) final AtomicReference
<Disposable> ObservablePublishSelector.SourceObserver.target
(package private) final AtomicReference
<Disposable> ObservableBufferTimed.BufferExactUnboundedObserver.timer
(package private) final AtomicReference
<Disposable> ObservableSampleTimed.SampleTimedObserver.timer
(package private) final AtomicReference
<Disposable> ObservableBufferBoundary.BufferBoundaryObserver.upstream
(package private) final AtomicReference
<Disposable> ObservablePublish.PublishConnection.upstream
(package private) final AtomicReference
<Disposable> ObservableRepeatWhen.RepeatWhenObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableRetryWhen.RepeatWhenObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableSubscribeOn.SubscribeOnObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableTakeUntil.TakeUntilMainObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableTimeout.TimeoutFallbackObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableTimeout.TimeoutObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableTimeoutTimed.TimeoutFallbackObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableTimeoutTimed.TimeoutObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableWindowBoundary.WindowBoundaryMainObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableWindowBoundarySelector.WindowBoundaryMainObserver.WindowEndObserverIntercept.upstream
(package private) final AtomicReference
<Disposable> ObservableWithLatestFrom.WithLatestFromObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableWithLatestFromMany.WithLatestFromObserver.upstream
(package private) final AtomicReference
<Disposable> ObservableZip.ZipObserver.upstream
(package private) final AtomicReference
<Disposable> ObserverResourceWrapper.upstream
Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type DisposableModifier and TypeMethodDescriptionvoid
ObservableRefCount.RefConnection.accept
(Disposable t) void
ObservableReplay.DisposeConsumer.accept
(Disposable r) (package private) void
ObservableBufferBoundary.BufferBoundaryObserver.boundaryError
(Disposable observer, Throwable ex) void
BlockingObservableIterable.BlockingObservableIterator.onSubscribe
(Disposable d) void
ObservableAll.AllObserver.onSubscribe
(Disposable d) void
ObservableAllSingle.AllObserver.onSubscribe
(Disposable d) void
ObservableAmb.AmbInnerObserver.onSubscribe
(Disposable d) void
ObservableAny.AnyObserver.onSubscribe
(Disposable d) void
ObservableAnySingle.AnyObserver.onSubscribe
(Disposable d) void
ObservableBuffer.BufferExactObserver.onSubscribe
(Disposable d) void
ObservableBuffer.BufferSkipObserver.onSubscribe
(Disposable d) void
ObservableBufferBoundary.BufferBoundaryObserver.BufferOpenObserver.onSubscribe
(Disposable d) void
ObservableBufferBoundary.BufferBoundaryObserver.onSubscribe
(Disposable d) void
ObservableBufferBoundary.BufferCloseObserver.onSubscribe
(Disposable d) void
ObservableBufferExactBoundary.BufferExactBoundaryObserver.onSubscribe
(Disposable d) void
ObservableBufferTimed.BufferExactBoundedObserver.onSubscribe
(Disposable d) void
ObservableBufferTimed.BufferExactUnboundedObserver.onSubscribe
(Disposable d) void
ObservableBufferTimed.BufferSkipBoundedObserver.onSubscribe
(Disposable d) void
ObservableCache.onSubscribe
(Disposable d) void
ObservableCollect.CollectObserver.onSubscribe
(Disposable d) void
ObservableCollectSingle.CollectObserver.onSubscribe
(Disposable d) void
ObservableCombineLatest.CombinerObserver.onSubscribe
(Disposable d) void
ObservableConcatMap.ConcatMapDelayErrorObserver.DelayErrorInnerObserver.onSubscribe
(Disposable d) void
ObservableConcatMap.ConcatMapDelayErrorObserver.onSubscribe
(Disposable d) void
ObservableConcatMap.SourceObserver.InnerObserver.onSubscribe
(Disposable d) void
ObservableConcatMap.SourceObserver.onSubscribe
(Disposable d) void
ObservableConcatMapEager.ConcatMapEagerMainObserver.onSubscribe
(Disposable d) void
ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.DelayErrorInnerObserver.onSubscribe
(Disposable d) void
ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.onSubscribe
(Disposable d) void
ObservableConcatMapScheduler.ConcatMapObserver.InnerObserver.onSubscribe
(Disposable d) void
ObservableConcatMapScheduler.ConcatMapObserver.onSubscribe
(Disposable d) void
ObservableConcatWithCompletable.ConcatWithObserver.onSubscribe
(Disposable d) void
ObservableConcatWithMaybe.ConcatWithObserver.onSubscribe
(Disposable d) void
ObservableConcatWithSingle.ConcatWithObserver.onSubscribe
(Disposable d) void
ObservableCount.CountObserver.onSubscribe
(Disposable d) void
ObservableCountSingle.CountObserver.onSubscribe
(Disposable d) void
ObservableDebounce.DebounceObserver.onSubscribe
(Disposable d) void
ObservableDebounceTimed.DebounceTimedObserver.onSubscribe
(Disposable d) void
ObservableDelay.DelayObserver.onSubscribe
(Disposable d) void
ObservableDelaySubscriptionOther.DelayObserver.OnComplete.onSubscribe
(Disposable d) void
ObservableDelaySubscriptionOther.DelayObserver.onSubscribe
(Disposable d) void
ObservableDematerialize.DematerializeObserver.onSubscribe
(Disposable d) void
ObservableDetach.DetachObserver.onSubscribe
(Disposable d) void
ObservableDoFinally.DoFinallyObserver.onSubscribe
(Disposable d) void
ObservableDoOnEach.DoOnEachObserver.onSubscribe
(Disposable d) void
ObservableElementAt.ElementAtObserver.onSubscribe
(Disposable d) void
ObservableElementAtMaybe.ElementAtObserver.onSubscribe
(Disposable d) void
ObservableElementAtSingle.ElementAtObserver.onSubscribe
(Disposable d) void
ObservableFlatMap.InnerObserver.onSubscribe
(Disposable d) void
ObservableFlatMap.MergeObserver.onSubscribe
(Disposable d) void
ObservableFlatMapCompletable.FlatMapCompletableMainObserver.InnerObserver.onSubscribe
(Disposable d) void
ObservableFlatMapCompletable.FlatMapCompletableMainObserver.onSubscribe
(Disposable d) void
ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.InnerObserver.onSubscribe
(Disposable d) void
ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.onSubscribe
(Disposable d) void
ObservableFlatMapMaybe.FlatMapMaybeObserver.InnerObserver.onSubscribe
(Disposable d) void
ObservableFlatMapMaybe.FlatMapMaybeObserver.onSubscribe
(Disposable d) void
ObservableFlatMapSingle.FlatMapSingleObserver.InnerObserver.onSubscribe
(Disposable d) void
ObservableFlatMapSingle.FlatMapSingleObserver.onSubscribe
(Disposable d) void
ObservableFlattenIterable.FlattenIterableObserver.onSubscribe
(Disposable d) void
ObservableFromCompletable.FromCompletableObserver.onSubscribe
(Disposable d) void
ObservableGroupBy.GroupByObserver.onSubscribe
(Disposable d) void
ObservableGroupJoin.LeftRightEndObserver.onSubscribe
(Disposable d) void
ObservableGroupJoin.LeftRightObserver.onSubscribe
(Disposable d) void
ObservableHide.HideDisposable.onSubscribe
(Disposable d) void
ObservableIgnoreElements.IgnoreObservable.onSubscribe
(Disposable d) void
ObservableIgnoreElementsCompletable.IgnoreObservable.onSubscribe
(Disposable d) void
ObservableLastMaybe.LastObserver.onSubscribe
(Disposable d) void
ObservableLastSingle.LastObserver.onSubscribe
(Disposable d) void
ObservableMapNotification.MapNotificationObserver.onSubscribe
(Disposable d) void
ObservableMaterialize.MaterializeObserver.onSubscribe
(Disposable d) void
ObservableMergeWithCompletable.MergeWithObserver.onSubscribe
(Disposable d) void
ObservableMergeWithCompletable.MergeWithObserver.OtherObserver.onSubscribe
(Disposable d) void
ObservableMergeWithMaybe.MergeWithObserver.onSubscribe
(Disposable d) void
ObservableMergeWithMaybe.MergeWithObserver.OtherObserver.onSubscribe
(Disposable d) void
ObservableMergeWithSingle.MergeWithObserver.onSubscribe
(Disposable d) void
ObservableMergeWithSingle.MergeWithObserver.OtherObserver.onSubscribe
(Disposable d) void
ObservableObserveOn.ObserveOnObserver.onSubscribe
(Disposable d) void
ObservableOnErrorComplete.OnErrorCompleteObserver.onSubscribe
(Disposable d) void
ObservableOnErrorNext.OnErrorNextObserver.onSubscribe
(Disposable d) void
ObservableOnErrorReturn.OnErrorReturnObserver.onSubscribe
(Disposable d) void
ObservablePublish.PublishConnection.onSubscribe
(Disposable d) void
ObservablePublishSelector.SourceObserver.onSubscribe
(Disposable d) void
ObservablePublishSelector.TargetObserver.onSubscribe
(Disposable d) void
ObservableReduceMaybe.ReduceObserver.onSubscribe
(Disposable d) void
ObservableReduceSeedSingle.ReduceSeedObserver.onSubscribe
(Disposable d) void
ObservableRefCount.RefCountObserver.onSubscribe
(Disposable d) void
ObservableRepeat.RepeatObserver.onSubscribe
(Disposable d) void
ObservableRepeatUntil.RepeatUntilObserver.onSubscribe
(Disposable d) void
ObservableRepeatWhen.RepeatWhenObserver.InnerRepeatObserver.onSubscribe
(Disposable d) void
ObservableRepeatWhen.RepeatWhenObserver.onSubscribe
(Disposable d) void
ObservableReplay.ReplayObserver.onSubscribe
(Disposable p) void
ObservableRetryBiPredicate.RetryBiObserver.onSubscribe
(Disposable d) void
ObservableRetryPredicate.RepeatObserver.onSubscribe
(Disposable d) void
ObservableRetryWhen.RepeatWhenObserver.InnerRepeatObserver.onSubscribe
(Disposable d) void
ObservableRetryWhen.RepeatWhenObserver.onSubscribe
(Disposable d) void
ObservableSampleTimed.SampleTimedObserver.onSubscribe
(Disposable d) void
ObservableSampleWithObservable.SampleMainObserver.onSubscribe
(Disposable d) void
ObservableSampleWithObservable.SamplerObserver.onSubscribe
(Disposable d) void
ObservableScan.ScanObserver.onSubscribe
(Disposable d) void
ObservableScanSeed.ScanSeedObserver.onSubscribe
(Disposable d) void
ObservableSequenceEqual.EqualObserver.onSubscribe
(Disposable d) void
ObservableSequenceEqualSingle.EqualObserver.onSubscribe
(Disposable d) void
ObservableSingleMaybe.SingleElementObserver.onSubscribe
(Disposable d) void
ObservableSingleSingle.SingleElementObserver.onSubscribe
(Disposable d) void
ObservableSkip.SkipObserver.onSubscribe
(Disposable d) void
ObservableSkipLast.SkipLastObserver.onSubscribe
(Disposable d) void
ObservableSkipLastTimed.SkipLastTimedObserver.onSubscribe
(Disposable d) void
ObservableSkipUntil.SkipUntil.onSubscribe
(Disposable d) void
ObservableSkipUntil.SkipUntilObserver.onSubscribe
(Disposable d) void
ObservableSkipWhile.SkipWhileObserver.onSubscribe
(Disposable d) void
ObservableSubscribeOn.SubscribeOnObserver.onSubscribe
(Disposable d) void
ObservableSwitchIfEmpty.SwitchIfEmptyObserver.onSubscribe
(Disposable d) void
ObservableSwitchMap.SwitchMapInnerObserver.onSubscribe
(Disposable d) void
ObservableSwitchMap.SwitchMapObserver.onSubscribe
(Disposable d) void
ObservableTake.TakeObserver.onSubscribe
(Disposable d) void
ObservableTakeLast.TakeLastObserver.onSubscribe
(Disposable d) void
ObservableTakeLastOne.TakeLastOneObserver.onSubscribe
(Disposable d) void
ObservableTakeLastTimed.TakeLastTimedObserver.onSubscribe
(Disposable d) void
ObservableTakeUntil.TakeUntilMainObserver.onSubscribe
(Disposable d) void
ObservableTakeUntil.TakeUntilMainObserver.OtherObserver.onSubscribe
(Disposable d) void
ObservableTakeUntilPredicate.TakeUntilPredicateObserver.onSubscribe
(Disposable d) void
ObservableTakeWhile.TakeWhileObserver.onSubscribe
(Disposable d) void
ObservableThrottleFirstTimed.DebounceTimedObserver.onSubscribe
(Disposable d) void
ObservableThrottleLatest.ThrottleLatestObserver.onSubscribe
(Disposable d) void
ObservableTimeInterval.TimeIntervalObserver.onSubscribe
(Disposable d) void
ObservableTimeout.TimeoutConsumer.onSubscribe
(Disposable d) void
ObservableTimeout.TimeoutFallbackObserver.onSubscribe
(Disposable d) void
ObservableTimeout.TimeoutObserver.onSubscribe
(Disposable d) void
ObservableTimeoutTimed.FallbackObserver.onSubscribe
(Disposable d) void
ObservableTimeoutTimed.TimeoutFallbackObserver.onSubscribe
(Disposable d) void
ObservableTimeoutTimed.TimeoutObserver.onSubscribe
(Disposable d) void
ObservableToList.ToListObserver.onSubscribe
(Disposable d) void
ObservableToListSingle.ToListObserver.onSubscribe
(Disposable d) void
ObservableUnsubscribeOn.UnsubscribeObserver.onSubscribe
(Disposable d) void
ObservableUsing.UsingObserver.onSubscribe
(Disposable d) void
ObservableWindow.WindowExactObserver.onSubscribe
(Disposable d) void
ObservableWindow.WindowSkipObserver.onSubscribe
(Disposable d) void
ObservableWindowBoundary.WindowBoundaryMainObserver.onSubscribe
(Disposable d) void
ObservableWindowBoundarySelector.WindowBoundaryMainObserver.onSubscribe
(Disposable d) void
ObservableWindowBoundarySelector.WindowBoundaryMainObserver.WindowEndObserverIntercept.onSubscribe
(Disposable d) void
ObservableWindowBoundarySelector.WindowBoundaryMainObserver.WindowStartObserver.onSubscribe
(Disposable d) final void
ObservableWindowTimed.AbstractWindowObserver.onSubscribe
(Disposable d) void
ObservableWithLatestFrom.WithLatestFromObserver.onSubscribe
(Disposable d) void
ObservableWithLatestFrom.WithLatestFromOtherObserver.onSubscribe
(Disposable d) void
ObservableWithLatestFromMany.WithLatestFromObserver.onSubscribe
(Disposable d) void
ObservableWithLatestFromMany.WithLatestInnerObserver.onSubscribe
(Disposable d) void
ObservableZip.ZipObserver.onSubscribe
(Disposable d) void
ObservableZipIterable.ZipIterableObserver.onSubscribe
(Disposable d) void
ObserverResourceWrapper.onSubscribe
(Disposable d) void
ObservableCreate.CreateEmitter.setDisposable
(Disposable d) void
ObservableCreate.SerializedEmitter.setDisposable
(Disposable d) (package private) boolean
ObservableSequenceEqual.EqualCoordinator.setDisposable
(Disposable d, int index) (package private) boolean
ObservableSequenceEqualSingle.EqualCoordinator.setDisposable
(Disposable d, int index) (package private) void
ObservableSubscribeOn.SubscribeOnObserver.setDisposable
(Disposable d) (package private) boolean
ObservableSampleWithObservable.SampleMainObserver.setOther
(Disposable o) boolean
ObservableWithLatestFrom.WithLatestFromObserver.setOther
(Disposable o) void
ObservableDebounceTimed.DebounceEmitter.setResource
(Disposable d) void
ObservableInterval.IntervalObserver.setResource
(Disposable d) void
ObservableIntervalRange.IntervalRangeObserver.setResource
(Disposable d) void
ObservableTimer.TimerObserver.setResource
(Disposable d) void
ObserverResourceWrapper.setResource
(Disposable resource) Method parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type DisposableModifier and TypeMethodDescriptionvoid
ObservablePublish.connect
(Consumer<? super Disposable> connection) void
ObservableReplay.connect
(Consumer<? super Disposable> connection) Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type DisposableModifierConstructorDescription(package private)
FallbackObserver
(Observer<? super T> actual, AtomicReference<Disposable> arbiter) ObservableAutoConnect
(ConnectableObservable<? extends T> source, int numberOfObservers, Consumer<? super Disposable> connection) ObservableDoOnLifecycle
(Observable<T> upstream, Consumer<? super Disposable> onSubscribe, Action onDispose) (package private)
SourceObserver
(PublishSubject<T> subject, AtomicReference<Disposable> target) -
Uses of Disposable in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement DisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.single declared as DisposableModifier and TypeFieldDescription(package private) Disposable
SingleFlatMapPublisher.SingleFlatMapPublisherObserver.disposable
(package private) Disposable
SingleUnsubscribeOn.UnsubscribeOnSingleObserver.ds
(package private) Disposable
SingleAmb.AmbSingleObserver.upstream
(package private) Disposable
SingleDematerialize.DematerializeObserver.upstream
(package private) Disposable
SingleDetach.DetachSingleObserver.upstream
(package private) Disposable
SingleDoAfterSuccess.DoAfterObserver.upstream
(package private) Disposable
SingleDoAfterTerminate.DoAfterTerminateObserver.upstream
(package private) Disposable
SingleDoFinally.DoFinallyObserver.upstream
(package private) Disposable
SingleDoOnDispose.DoOnDisposeObserver.upstream
(package private) Disposable
SingleDoOnLifecycle.SingleLifecycleObserver.upstream
(package private) Disposable
SingleFlatMapIterableFlowable.FlatMapIterableObserver.upstream
(package private) Disposable
SingleFlatMapIterableObservable.FlatMapIterableObserver.upstream
(package private) Disposable
SingleFlatMapNotification.FlatMapSingleObserver.upstream
(package private) Disposable
SingleHide.HideSingleObserver.upstream
(package private) Disposable
SingleTimeInterval.TimeIntervalSingleObserver.upstream
(package private) Disposable
SingleToFlowable.SingleToFlowableObserver.upstream
(package private) Disposable
SingleToObservable.SingleToObservableObserver.upstream
(package private) Disposable
SingleUsing.UsingSingleObserver.upstream
Fields in io.reactivex.rxjava3.internal.operators.single with type parameters of type DisposableModifier and TypeFieldDescription(package private) final Consumer
<? super Disposable> SingleDoOnLifecycle.onSubscribe
(package private) final Consumer
<? super Disposable> SingleDoOnLifecycle.SingleLifecycleObserver.onSubscribe
(package private) final Consumer
<? super Disposable> SingleDoOnSubscribe.DoOnSubscribeSingleObserver.onSubscribe
(package private) final Consumer
<? super Disposable> SingleDoOnSubscribe.onSubscribe
(package private) final AtomicReference
<Disposable> SingleFlatMap.SingleFlatMapCallback.FlatMapSingleObserver.parent
(package private) final AtomicReference
<Disposable> SingleFlatMapMaybe.FlatMapMaybeObserver.parent
(package private) final AtomicReference
<Disposable> SingleTimeout.TimeoutMainObserver.task
Methods in io.reactivex.rxjava3.internal.operators.single with parameters of type DisposableModifier and TypeMethodDescriptionvoid
SingleAmb.AmbSingleObserver.onSubscribe
(Disposable d) void
SingleCache.onSubscribe
(Disposable d) void
SingleContains.ContainsSingleObserver.onSubscribe
(Disposable d) void
SingleDelay.Delay.onSubscribe
(Disposable d) void
SingleDelayWithCompletable.OtherObserver.onSubscribe
(Disposable d) void
SingleDelayWithObservable.OtherSubscriber.onSubscribe
(Disposable d) void
SingleDelayWithSingle.OtherObserver.onSubscribe
(Disposable d) void
SingleDematerialize.DematerializeObserver.onSubscribe
(Disposable d) void
SingleDetach.DetachSingleObserver.onSubscribe
(Disposable d) void
SingleDoAfterSuccess.DoAfterObserver.onSubscribe
(Disposable d) void
SingleDoAfterTerminate.DoAfterTerminateObserver.onSubscribe
(Disposable d) void
SingleDoFinally.DoFinallyObserver.onSubscribe
(Disposable d) void
SingleDoOnDispose.DoOnDisposeObserver.onSubscribe
(Disposable d) void
SingleDoOnError.DoOnError.onSubscribe
(Disposable d) void
SingleDoOnEvent.DoOnEvent.onSubscribe
(Disposable d) void
SingleDoOnLifecycle.SingleLifecycleObserver.onSubscribe
(@NonNull Disposable d) void
SingleDoOnSubscribe.DoOnSubscribeSingleObserver.onSubscribe
(Disposable d) void
SingleDoOnSuccess.DoOnSuccess.onSubscribe
(Disposable d) void
SingleDoOnTerminate.DoOnTerminate.onSubscribe
(Disposable d) void
SingleEquals.InnerObserver.onSubscribe
(Disposable d) void
SingleFlatMap.SingleFlatMapCallback.FlatMapSingleObserver.onSubscribe
(Disposable d) void
SingleFlatMap.SingleFlatMapCallback.onSubscribe
(Disposable d) void
SingleFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver.onSubscribe
(Disposable d) void
SingleFlatMapBiSelector.FlatMapBiMainObserver.onSubscribe
(Disposable d) void
SingleFlatMapCompletable.FlatMapCompletableObserver.onSubscribe
(Disposable d) void
SingleFlatMapIterableFlowable.FlatMapIterableObserver.onSubscribe
(Disposable d) void
SingleFlatMapIterableObservable.FlatMapIterableObserver.onSubscribe
(Disposable d) void
SingleFlatMapMaybe.FlatMapMaybeObserver.onSubscribe
(Disposable d) void
SingleFlatMapMaybe.FlatMapSingleObserver.onSubscribe
(Disposable d) void
SingleFlatMapNotification.FlatMapSingleObserver.InnerObserver.onSubscribe
(Disposable d) void
SingleFlatMapNotification.FlatMapSingleObserver.onSubscribe
(Disposable d) void
SingleFlatMapPublisher.SingleFlatMapPublisherObserver.onSubscribe
(Disposable d) void
SingleHide.HideSingleObserver.onSubscribe
(Disposable d) void
SingleMap.MapSingleObserver.onSubscribe
(Disposable d) void
SingleObserveOn.ObserveOnSingleObserver.onSubscribe
(Disposable d) void
SingleOnErrorReturn.OnErrorReturn.onSubscribe
(Disposable d) void
SingleResumeNext.ResumeMainSingleObserver.onSubscribe
(Disposable d) void
SingleSubscribeOn.SubscribeOnObserver.onSubscribe
(Disposable d) void
SingleTakeUntil.TakeUntilMainObserver.onSubscribe
(Disposable d) void
SingleTimeInterval.TimeIntervalSingleObserver.onSubscribe
(@NonNull Disposable d) void
SingleTimeout.TimeoutMainObserver.onSubscribe
(Disposable d) void
SingleTimeout.TimeoutMainObserver.TimeoutFallbackObserver.onSubscribe
(Disposable d) void
SingleToFlowable.SingleToFlowableObserver.onSubscribe
(Disposable d) void
SingleToObservable.SingleToObservableObserver.onSubscribe
(Disposable d) void
SingleUnsubscribeOn.UnsubscribeOnSingleObserver.onSubscribe
(Disposable d) void
SingleUsing.UsingSingleObserver.onSubscribe
(Disposable d) void
SingleZipArray.ZipSingleObserver.onSubscribe
(Disposable d) void
SingleCreate.Emitter.setDisposable
(Disposable d) (package private) void
SingleTimer.TimerDisposable.setFuture
(Disposable d) Constructor parameters in io.reactivex.rxjava3.internal.operators.single with type arguments of type DisposableModifierConstructorDescription(package private)
DoOnSubscribeSingleObserver
(SingleObserver<? super T> actual, Consumer<? super Disposable> onSubscribe) (package private)
FlatMapMaybeObserver
(AtomicReference<Disposable> parent, MaybeObserver<? super R> downstream) (package private)
FlatMapSingleObserver
(AtomicReference<Disposable> parent, SingleObserver<? super R> downstream) SingleDoOnLifecycle
(Single<T> upstream, Consumer<? super Disposable> onSubscribe, Action onDispose) SingleDoOnSubscribe
(SingleSource<T> source, Consumer<? super Disposable> onSubscribe) (package private)
SingleLifecycleObserver
(SingleObserver<? super T> downstream, Consumer<? super Disposable> onSubscribe, Action onDispose) -
Uses of Disposable in io.reactivex.rxjava3.internal.schedulers
Classes in io.reactivex.rxjava3.internal.schedulers that implement DisposableModifier and TypeClassDescription(package private) class
Base functionality for direct tasks that manage a runnable and cancellation/completion.(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
Wrapper for aRunnable
with additional logic for handling interruption on a shared thread, similar to how Java Executors do it.(package private) static final class
(package private) final class
Wrapper for a regular task that gets immediately rescheduled when the task completed.(package private) static final class
(package private) static final class
class
Base class that manages a single-threaded ScheduledExecutorService as a worker but doesn't perform task-tracking operations.final class
A Callable to be submitted to an ExecutorService that runs a Runnable action periodically and manages completion/cancellation.final class
A Callable to be submitted to an ExecutorService that runs a Runnable action and manages completion/cancellation.final class
class
Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.(package private) static class
(package private) static class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.schedulers declared as DisposableModifier and TypeFieldDescriptionprivate Disposable
SchedulerWhen.disposable
(package private) static final Disposable
ImmediateThinScheduler.DISPOSED
(package private) static final Disposable
SchedulerWhen.DISPOSED
(package private) static final Disposable
SchedulerWhen.SUBSCRIBED
(package private) final Disposable
DisposeOnCancel.upstream
Methods in io.reactivex.rxjava3.internal.schedulers that return DisposableModifier and TypeMethodDescriptionprotected Disposable
SchedulerWhen.DelayedAction.callActual
(Scheduler.Worker actualWorker, CompletableObserver actionCompletable) protected Disposable
SchedulerWhen.ImmediateAction.callActual
(Scheduler.Worker actualWorker, CompletableObserver actionCompletable) protected abstract Disposable
SchedulerWhen.ScheduledAction.callActual
(Scheduler.Worker actualWorker, CompletableObserver actionCompletable) (package private) Disposable
ComputationScheduler.EventLoopWorker.schedule
(@NonNull Runnable action, long delayTime, @NonNull TimeUnit unit) ExecutorScheduler.ExecutorWorker.schedule
(@NonNull Runnable run, long delay, @NonNull TimeUnit unit) ImmediateThinScheduler.ImmediateThinWorker.schedule
(@NonNull Runnable run, long delay, @NonNull TimeUnit unit) IoScheduler.EventLoopWorker.schedule
(@NonNull Runnable action, long delayTime, @NonNull TimeUnit unit) SchedulerWhen.QueueWorker.schedule
(@NonNull Runnable action, long delayTime, @NonNull TimeUnit unit) TrampolineScheduler.TrampolineWorker.schedule
(@NonNull Runnable action, long delayTime, @NonNull TimeUnit unit) ComputationScheduler.scheduleDirect
(@NonNull Runnable run, long delay, TimeUnit unit) ExecutorScheduler.scheduleDirect
(@NonNull Runnable run) ExecutorScheduler.scheduleDirect
(@NonNull Runnable run, long delay, TimeUnit unit) ImmediateThinScheduler.scheduleDirect
(@NonNull Runnable run) ImmediateThinScheduler.scheduleDirect
(@NonNull Runnable run, long delay, TimeUnit unit) NewThreadWorker.scheduleDirect
(Runnable run, long delayTime, TimeUnit unit) Schedules the given runnable on the underlying executor directly and returns its future wrapped into a Disposable.SingleScheduler.scheduleDirect
(@NonNull Runnable run, long delay, TimeUnit unit) TrampolineScheduler.scheduleDirect
(@NonNull Runnable run) TrampolineScheduler.scheduleDirect
(@NonNull Runnable run, long delay, TimeUnit unit) ImmediateThinScheduler.ImmediateThinWorker.schedulePeriodically
(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit) ComputationScheduler.schedulePeriodicallyDirect
(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit) ExecutorScheduler.schedulePeriodicallyDirect
(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit) ImmediateThinScheduler.schedulePeriodicallyDirect
(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit) NewThreadWorker.schedulePeriodicallyDirect
(Runnable run, long initialDelay, long period, TimeUnit unit) Schedules the given runnable periodically on the underlying executor directly and returns its future wrapped into a Disposable.SingleScheduler.schedulePeriodicallyDirect
(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit) Constructors in io.reactivex.rxjava3.internal.schedulers with parameters of type Disposable -
Uses of Disposable in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement DisposableModifier and TypeClassDescriptionfinal class
final class
Wraps lambda callbacks and when the upstream terminates or this subscriber gets disposed, removes itself from aCompositeDisposable
.final class
final class
final class
Methods in io.reactivex.rxjava3.internal.subscribers with parameters of type DisposableModifier and TypeMethodDescriptionprotected final void
QueueDrainSubscriber.fastPathEmitMax
(U value, boolean delayError, Disposable dispose) protected final void
QueueDrainSubscriber.fastPathOrderedEmitMax
(U value, boolean delayError, Disposable dispose) void
SubscriberResourceWrapper.setResource
(Disposable resource) -
Uses of Disposable in io.reactivex.rxjava3.internal.subscriptions
Classes in io.reactivex.rxjava3.internal.subscriptions that implement DisposableModifier and TypeClassDescriptionfinal class
A composite disposable with a fixed number of slots.final class
A subscription implementation that arbitrates exactly one other Subscription and can hold a single disposable resource.Fields in io.reactivex.rxjava3.internal.subscriptions with type parameters of type DisposableModifier and TypeFieldDescription(package private) final AtomicReference
<Disposable> AsyncSubscription.resource
Methods in io.reactivex.rxjava3.internal.subscriptions with parameters of type DisposableModifier and TypeMethodDescriptionboolean
AsyncSubscription.replaceResource
(Disposable r) Replaces the currently held resource with the given new one without disposing the old.boolean
AsyncSubscription.setResource
(Disposable r) Sets a new resource and disposes the currently held resource.Constructors in io.reactivex.rxjava3.internal.subscriptions with parameters of type Disposable -
Uses of Disposable in io.reactivex.rxjava3.internal.util
Classes in io.reactivex.rxjava3.internal.util that implement DisposableModifier and TypeClassDescriptionenum
Singleton implementing many interfaces as empty.Fields in io.reactivex.rxjava3.internal.util declared as DisposableModifier and TypeFieldDescriptionConnectConsumer.disposable
(package private) final Disposable
NotificationLite.DisposableNotification.upstream
Methods in io.reactivex.rxjava3.internal.util that return DisposableMethods in io.reactivex.rxjava3.internal.util with parameters of type DisposableModifier and TypeMethodDescriptionvoid
ConnectConsumer.accept
(Disposable t) static void
BlockingHelper.awaitForComplete
(CountDownLatch latch, Disposable subscription) static <T,
U> boolean QueueDrainHelper.checkTerminated
(boolean d, boolean empty, Observer<?> observer, boolean delayError, SimpleQueue<?> q, Disposable disposable, ObservableQueueDrain<T, U> qd) static Object
NotificationLite.disposable
(Disposable d) Converts a Disposable into a notification value.static <T,
U> void QueueDrainHelper.drainLoop
(SimplePlainQueue<T> q, Observer<? super U> a, boolean delayError, Disposable dispose, ObservableQueueDrain<T, U> qd) static <T,
U> void QueueDrainHelper.drainMaxLoop
(SimplePlainQueue<T> q, org.reactivestreams.Subscriber<? super U> a, boolean delayError, Disposable dispose, QueueDrain<T, U> qd) Drain the queue but give up with an error if there aren't enough requests.void
EmptyComponent.onSubscribe
(Disposable d) static boolean
EndConsumerHelper.setOnce
(AtomicReference<Disposable> upstream, Disposable next, Class<?> observer) Atomically updates the target upstream AtomicReference from null to the non-null next Disposable, otherwise disposes next and reports a ProtocolViolationException if the AtomicReference doesn't contain the shared disposed indicator.static boolean
EndConsumerHelper.validate
(Disposable upstream, Disposable next, Class<?> observer) Ensures that the upstream Disposable is null and returns true, otherwise disposes the next Disposable and if the upstream is not the shared disposed instance, reports a ProtocolViolationException due to multiple subscribe attempts.Method parameters in io.reactivex.rxjava3.internal.util with type arguments of type DisposableModifier and TypeMethodDescriptionstatic boolean
EndConsumerHelper.setOnce
(AtomicReference<Disposable> upstream, Disposable next, Class<?> observer) Atomically updates the target upstream AtomicReference from null to the non-null next Disposable, otherwise disposes next and reports a ProtocolViolationException if the AtomicReference doesn't contain the shared disposed indicator.Constructors in io.reactivex.rxjava3.internal.util with parameters of type Disposable -
Uses of Disposable in io.reactivex.rxjava3.observables
Methods in io.reactivex.rxjava3.observables that return DisposableModifier and TypeMethodDescriptionfinal @NonNull Disposable
ConnectableObservable.connect()
Instructs theConnectableObservable
to begin emitting the items from its underlyingObservable
to itsObserver
s.Method parameters in io.reactivex.rxjava3.observables with type arguments of type DisposableModifier and TypeMethodDescriptionConnectableObservable.autoConnect
(int numberOfObservers, @NonNull Consumer<? super Disposable> connection) Returns anObservable
that automatically connects (at most once) to thisConnectableObservable
when the specified number ofObserver
s subscribe to it and calls the specified callback with theDisposable
associated with the established connection.abstract void
ConnectableObservable.connect
(@NonNull Consumer<? super Disposable> connection) Instructs theConnectableObservable
to begin emitting the items from its underlyingObservable
to itsObserver
s. -
Uses of Disposable in io.reactivex.rxjava3.observers
Classes in io.reactivex.rxjava3.observers that implement DisposableModifier and TypeClassDescriptionclass
An abstractCompletableObserver
that allows asynchronous cancellation by implementing Disposable.class
An abstractMaybeObserver
that allows asynchronous cancellation by implementingDisposable
.class
An abstractObserver
that allows asynchronous cancellation by implementingDisposable
.class
An abstractSingleObserver
that allows asynchronous cancellation by implementingDisposable
.class
An abstractCompletableObserver
that allows asynchronous cancellation of its subscription and associated resources.class
An abstractMaybeObserver
that allows asynchronous cancellation of its subscription and associated resources.class
An abstractObserver
that allows asynchronous cancellation of its subscription and associated resources.class
An abstractSingleObserver
that allows asynchronous cancellation of its subscription and the associated resources.final class
SafeObserver<T>
Wraps anotherObserver
and ensures allonXXX
methods conform the protocol (except the requirement for serialized access).final class
Serializes access to theObserver.onNext(Object)
,Observer.onError(Throwable)
andObserver.onComplete()
methods of anotherObserver
.class
TestObserver<T>
AnObserver
,MaybeObserver
,SingleObserver
andCompletableObserver
composite that can record events fromObservable
s,Maybe
s,Single
s andCompletable
s and allows making assertions about them.Fields in io.reactivex.rxjava3.observers declared as DisposableModifier and TypeFieldDescriptionprivate Disposable
DefaultObserver.upstream
(package private) Disposable
SafeObserver.upstream
The subscription.(package private) Disposable
SerializedObserver.upstream
Fields in io.reactivex.rxjava3.observers with type parameters of type DisposableModifier and TypeFieldDescription(package private) final AtomicReference
<Disposable> DisposableCompletableObserver.upstream
(package private) final AtomicReference
<Disposable> DisposableMaybeObserver.upstream
(package private) final AtomicReference
<Disposable> DisposableObserver.upstream
(package private) final AtomicReference
<Disposable> DisposableSingleObserver.upstream
private final AtomicReference
<Disposable> ResourceCompletableObserver.upstream
The active subscription.private final AtomicReference
<Disposable> ResourceMaybeObserver.upstream
The active subscription.private final AtomicReference
<Disposable> ResourceObserver.upstream
The active subscription.private final AtomicReference
<Disposable> ResourceSingleObserver.upstream
The active subscription.private final AtomicReference
<Disposable> TestObserver.upstream
Holds the current subscription if any.Methods in io.reactivex.rxjava3.observers with parameters of type DisposableModifier and TypeMethodDescriptionfinal void
ResourceCompletableObserver.add
(@NonNull Disposable resource) Adds a resource to thisResourceCompletableObserver
.final void
ResourceMaybeObserver.add
(@NonNull Disposable resource) Adds a resource to thisResourceMaybeObserver
.final void
ResourceObserver.add
(@NonNull Disposable resource) Adds a resource to thisResourceObserver
.final void
ResourceSingleObserver.add
(@NonNull Disposable resource) Adds a resource to thisResourceSingleObserver
.final void
DefaultObserver.onSubscribe
(@NonNull Disposable d) final void
DisposableCompletableObserver.onSubscribe
(@NonNull Disposable d) final void
DisposableMaybeObserver.onSubscribe
(@NonNull Disposable d) final void
DisposableObserver.onSubscribe
(@NonNull Disposable d) final void
DisposableSingleObserver.onSubscribe
(@NonNull Disposable d) final void
ResourceCompletableObserver.onSubscribe
(@NonNull Disposable d) final void
ResourceMaybeObserver.onSubscribe
(@NonNull Disposable d) final void
ResourceObserver.onSubscribe
(Disposable d) final void
ResourceSingleObserver.onSubscribe
(@NonNull Disposable d) void
SafeObserver.onSubscribe
(@NonNull Disposable d) void
SerializedObserver.onSubscribe
(@NonNull Disposable d) void
TestObserver.EmptyObserver.onSubscribe
(Disposable d) void
TestObserver.onSubscribe
(@NonNull Disposable d) -
Uses of Disposable in io.reactivex.rxjava3.operators
Subinterfaces of Disposable in io.reactivex.rxjava3.operatorsModifier and TypeInterfaceDescriptioninterface
An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type. -
Uses of Disposable in io.reactivex.rxjava3.schedulers
Classes in io.reactivex.rxjava3.schedulers that implement DisposableModifier and TypeClassDescription(package private) final class
(package private) final class
Methods in io.reactivex.rxjava3.schedulers that return Disposable -
Uses of Disposable in io.reactivex.rxjava3.subjects
Classes in io.reactivex.rxjava3.subjects that implement DisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Wraps the actual subscriber, tracks its requests and makes cancellation to remove itself from the current subscribers array.(package private) static final class
(package private) static final class
(package private) final class
Methods in io.reactivex.rxjava3.subjects with parameters of type DisposableModifier and TypeMethodDescriptionvoid
AsyncSubject.onSubscribe
(Disposable d) void
BehaviorSubject.onSubscribe
(Disposable d) void
CompletableSubject.onSubscribe
(Disposable d) void
MaybeSubject.onSubscribe
(Disposable d) void
PublishSubject.onSubscribe
(Disposable d) void
ReplaySubject.onSubscribe
(Disposable d) void
SerializedSubject.onSubscribe
(Disposable d) void
SingleSubject.onSubscribe
(@NonNull Disposable d) void
UnicastSubject.onSubscribe
(Disposable d) -
Uses of Disposable in io.reactivex.rxjava3.subscribers
Classes in io.reactivex.rxjava3.subscribers that implement DisposableModifier and TypeClassDescriptionclass
An abstract Subscriber that allows asynchronous, external cancellation by implementingDisposable
.class
An abstract Subscriber that allows asynchronous cancellation of its subscription and associated resources.Methods in io.reactivex.rxjava3.subscribers with parameters of type DisposableModifier and TypeMethodDescriptionfinal void
ResourceSubscriber.add
(Disposable resource) Adds a resource to thisResourceSubscriber
.