Uses of Package
io.reactivex.rxjava3.core
-
Packages that use io.reactivex.rxjava3.core Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable
,Observable
,Single
,Maybe
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.flowables Classes supporting the Flowable base reactive class:ConnectableFlowable
andGroupedFlowable
.io.reactivex.rxjava3.internal.disposables io.reactivex.rxjava3.internal.functions io.reactivex.rxjava3.internal.fuseable Base interfaces and types for supporting operator-fusion.io.reactivex.rxjava3.internal.jdk8 io.reactivex.rxjava3.internal.observers io.reactivex.rxjava3.internal.operators.completable io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.operators.maybe io.reactivex.rxjava3.internal.operators.mixed io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.internal.operators.parallel io.reactivex.rxjava3.internal.operators.single io.reactivex.rxjava3.internal.schedulers io.reactivex.rxjava3.internal.subscribers io.reactivex.rxjava3.internal.util io.reactivex.rxjava3.observables Classes supporting the Observable base reactive class:ConnectableObservable
andGroupedObservable
.io.reactivex.rxjava3.observers Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and theTestObserver
that allows unit testingObservable
-,Single
-,Maybe
- andCompletable
-based flows.io.reactivex.rxjava3.operators Classes and interfaces for writing advanced operators within and outside RxJava.io.reactivex.rxjava3.parallel Contains the base typeParallelFlowable
, a sub-DSL for working withFlowable
sequences in parallel.io.reactivex.rxjava3.plugins Contains the central plugin handlerRxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.io.reactivex.rxjava3.processors Classes representing so-called hot backpressure-aware sources, aka processors, that implement theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
.io.reactivex.rxjava3.schedulers Contains notably the factory class ofSchedulers
providing methods for retrieving the standard scheduler instances, theTestScheduler
for testing flows with scheduling in a controlled manner and the classTimed
that can hold a value and a timestamp associated with it.io.reactivex.rxjava3.subjects 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.io.reactivex.rxjava3.subscribers Default wrappers and implementations forSubscriber
-based consumer classes and interfaces, including disposable (DisposableSubscriber
) and resource-tracking (ResourceSubscriber
) variants and theTestSubscriber
that allows unit testingFlowable
-based flows. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.core Class Description BackpressureOverflowStrategy Options to deal with buffer overflow when using onBackpressureBuffer.BackpressureStrategy Represents the options for applying backpressure to a source sequence.Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableConverter Convenience interface and callback used by theCompletable.to(io.reactivex.rxjava3.core.CompletableConverter<? extends R>)
operator to turn a Completable into another value fluently.CompletableEmitter Abstraction over an RxJavaCompletableObserver
that allows associating a resource with it.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableOnSubscribe A functional interface that has asubscribe()
method that receives aCompletableEmitter
instance that allows pushing an event in a cancellation-safe manner.CompletableOperator Interface to map/wrap a downstream observer to an upstream observer.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.CompletableTransformer Convenience interface and callback used by the compose operator to turn aCompletable
into anotherCompletable
fluently.Emitter Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableConverter Convenience interface and callback used by theFlowable.to(io.reactivex.rxjava3.core.FlowableConverter<T, ? extends R>)
operator to turn aFlowable
into another value fluently.FlowableEmitter Abstraction over a Reactive StreamsSubscriber
that allows associating a resource with it and exposes the current number of downstream requested amount.FlowableOnSubscribe A functional interface that has asubscribe()
method that receives aFlowableEmitter
instance that allows pushing events in a backpressure-safe and cancellation-safe manner.FlowableOperator Interface to map/wrap a downstreamSubscriber
to an upstreamSubscriber
.FlowableSubscriber FlowableTransformer Interface to composeFlowable
s.Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeConverter Convenience interface and callback used by theMaybe.to(io.reactivex.rxjava3.core.MaybeConverter<T, ? extends R>)
operator to turn aMaybe
into another value fluently.MaybeEmitter Abstraction over an RxJavaMaybeObserver
that allows associating a resource with it.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.MaybeOnSubscribe A functional interface that has asubscribe()
method that receives aMaybeEmitter
instance that allows pushing an event in a cancellation-safe manner.MaybeOperator Interface to map/wrap a downstreamMaybeObserver
to an upstreamMaybeObserver
.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.MaybeTransformer Interface to composeMaybe
s.Notification Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableConverter Convenience interface and callback used by theObservable.to(io.reactivex.rxjava3.core.ObservableConverter<T, ? extends R>)
operator to turn anObservable
into another value fluently.ObservableEmitter Abstraction over an RxJavaObserver
that allows associating a resource with it.ObservableOnSubscribe A functional interface that has asubscribe()
method that receives anObservableEmitter
instance that allows pushing events in a cancellation-safe manner.ObservableOperator Interface to map/wrap a downstreamObserver
to an upstreamObserver
.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.ObservableTransformer Interface to composeObservable
s.Observer Provides a mechanism for receiving push-based notifications.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Scheduler.Worker 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).Single TheSingle
class implements the Reactive Pattern for a single value response.SingleConverter Convenience interface and callback used by theSingle.to(io.reactivex.rxjava3.core.SingleConverter<T, ? extends R>)
operator to turn aSingle
into another value fluently.SingleEmitter Abstraction over an RxJavaSingleObserver
that allows associating a resource with it.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error.SingleOnSubscribe A functional interface that has asubscribe()
method that receives aSingleEmitter
instance that allows pushing an event in a cancellation-safe manner.SingleOperator Interface to map/wrap a downstreamSingleObserver
to an upstreamSingleObserver
.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
.SingleTransformer Interface to composeSingle
s. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.flowables Class Description Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.disposables Class Description CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Observer Provides a mechanism for receiving push-based notifications.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.functions Class Description Notification Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.fuseable Class Description CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.jdk8 Class Description Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Observer Provides a mechanism for receiving push-based notifications.Single TheSingle
class implements the Reactive Pattern for a single value response.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.observers Class Description CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Observer Provides a mechanism for receiving push-based notifications.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.completable Class Description Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableEmitter Abstraction over an RxJavaCompletableObserver
that allows associating a resource with it.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableOnSubscribe A functional interface that has asubscribe()
method that receives aCompletableEmitter
instance that allows pushing an event in a cancellation-safe manner.CompletableOperator Interface to map/wrap a downstream observer to an upstream observer.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Notification Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Observer Provides a mechanism for receiving push-based notifications.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Single TheSingle
class implements the Reactive Pattern for a single value response.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.flowable Class Description BackpressureOverflowStrategy Options to deal with buffer overflow when using onBackpressureBuffer.BackpressureStrategy Represents the options for applying backpressure to a source sequence.Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Emitter Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableEmitter Abstraction over a Reactive StreamsSubscriber
that allows associating a resource with it and exposes the current number of downstream requested amount.FlowableOnSubscribe A functional interface that has asubscribe()
method that receives aFlowableEmitter
instance that allows pushing events in a backpressure-safe and cancellation-safe manner.FlowableOperator Interface to map/wrap a downstreamSubscriber
to an upstreamSubscriber
.FlowableSubscriber Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Notification Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Observer Provides a mechanism for receiving push-based notifications.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Scheduler.Worker 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).Single TheSingle
class implements the Reactive Pattern for a single value response.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.maybe Class Description Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeEmitter Abstraction over an RxJavaMaybeObserver
that allows associating a resource with it.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.MaybeOnSubscribe A functional interface that has asubscribe()
method that receives aMaybeEmitter
instance that allows pushing an event in a cancellation-safe manner.MaybeOperator Interface to map/wrap a downstreamMaybeObserver
to an upstreamMaybeObserver
.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Notification Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Observer Provides a mechanism for receiving push-based notifications.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Single TheSingle
class implements the Reactive Pattern for a single value response.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.mixed Class Description Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Notification Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Observer Provides a mechanism for receiving push-based notifications.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.observable Class Description Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Emitter Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).FlowableSubscriber Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Notification Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableEmitter Abstraction over an RxJavaObserver
that allows associating a resource with it.ObservableOnSubscribe A functional interface that has asubscribe()
method that receives anObservableEmitter
instance that allows pushing events in a cancellation-safe manner.ObservableOperator Interface to map/wrap a downstreamObserver
to an upstreamObserver
.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Observer Provides a mechanism for receiving push-based notifications.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Scheduler.Worker 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).Single TheSingle
class implements the Reactive Pattern for a single value response.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.parallel Class Description Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Scheduler.Worker 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). -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.single Class Description Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Notification Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Observer Provides a mechanism for receiving push-based notifications.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Single TheSingle
class implements the Reactive Pattern for a single value response.SingleEmitter Abstraction over an RxJavaSingleObserver
that allows associating a resource with it.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error.SingleOnSubscribe A functional interface that has asubscribe()
method that receives aSingleEmitter
instance that allows pushing an event in a cancellation-safe manner.SingleOperator Interface to map/wrap a downstreamSingleObserver
to an upstreamSingleObserver
.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.schedulers Class Description Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Scheduler.Worker 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). -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.subscribers Class Description FlowableSubscriber -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.util Class Description CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.Emitter Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).FlowableSubscriber MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Observer Provides a mechanism for receiving push-based notifications.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.observables Class Description Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.observers Class Description CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Observer Provides a mechanism for receiving push-based notifications.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.operators Class Description FlowableSubscriber -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.parallel Class Description Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.plugins Class Description Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.Observer Provides a mechanism for receiving push-based notifications.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Single TheSingle
class implements the Reactive Pattern for a single value response.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.processors Class Description Flowable TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.schedulers Class Description Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Scheduler.Worker 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). -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.subjects Class Description Completable TheCompletable
class represents a deferred computation without any value but only indication for completion or exception.CompletableObserver Provides a mechanism for receiving push-based notification of a valueless completion or an error.CompletableSource Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Maybe TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.MaybeObserver Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.MaybeSource Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Observable TheObservable
class is the non-backpressured, optionally multi-valued base reactive class that offers factory methods, intermediate operators and the ability to consume synchronous and/or asynchronous reactive dataflows.ObservableSource Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Observer Provides a mechanism for receiving push-based notifications.Scheduler AScheduler
is an object that specifies an API for scheduling units of work provided in the form ofRunnable
s to be executed without delay (effectively as soon as possible), after a specified time delay or periodically and represents an abstraction over an asynchronous boundary that ensures these units of work get executed by some underlying task-execution scheme (such as custom Threads, event loop,Executor
or Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Single TheSingle
class implements the Reactive Pattern for a single value response.SingleObserver Provides a mechanism for receiving push-based notification of a single value or an error.SingleSource Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.subscribers Class Description FlowableSubscriber