Uses of Package
io.reactivex.rxjava3.core
Packages that use io.reactivex.rxjava3.core
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.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 the base type
ParallelFlowable
,
a sub-DSL for working with Flowable
sequences in parallel.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.Classes representing so-called hot backpressure-aware sources, aka processors,
that implement the
FlowableProcessor
class,
the Reactive Streams Processor
interface
to allow forms of multicasting events to one or more subscribers as well as consuming another
Reactive Streams Publisher
.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.-
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.coreClassDescriptionOptions to deal with buffer overflow when using onBackpressureBuffer.Represents the options for applying backpressure to a source sequence.The
Completable
class represents a deferred computation without any value but only indication for completion or exception.Convenience interface and callback used by theCompletable.to(io.reactivex.rxjava3.core.CompletableConverter<? extends R>)
operator to turn a Completable into another value fluently.Abstraction over an RxJavaCompletableObserver
that allows associating a resource with it.Provides a mechanism for receiving push-based notification of a valueless completion or an error.A functional interface that has asubscribe()
method that receives aCompletableEmitter
instance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstream observer to an upstream observer.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Convenience interface and callback used by the compose operator to turn aCompletable
into anotherCompletable
fluently.Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Convenience interface and callback used by theFlowable.to(io.reactivex.rxjava3.core.FlowableConverter<T, ? extends R>)
operator to turn aFlowable
into another value fluently.Abstraction over a Reactive StreamsSubscriber
that allows associating a resource with it and exposes the current number of downstream requested amount.A functional interface that has asubscribe()
method that receives aFlowableEmitter
instance that allows pushing events in a backpressure-safe and cancellation-safe manner.Interface to map/wrap a downstreamSubscriber
to an upstreamSubscriber
.Interface to composeFlowable
s.TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Convenience interface and callback used by theMaybe.to(io.reactivex.rxjava3.core.MaybeConverter<T, ? extends R>)
operator to turn aMaybe
into another value fluently.Abstraction over an RxJavaMaybeObserver
that allows associating a resource with it.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.A functional interface that has asubscribe()
method that receives aMaybeEmitter
instance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstreamMaybeObserver
to an upstreamMaybeObserver
.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Interface to composeMaybe
s.Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).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.Convenience interface and callback used by theObservable.to(io.reactivex.rxjava3.core.ObservableConverter<T, ? extends R>)
operator to turn anObservable
into another value fluently.Abstraction over an RxJavaObserver
that allows associating a resource with it.A functional interface that has asubscribe()
method that receives anObservableEmitter
instance that allows pushing events in a cancellation-safe manner.Interface to map/wrap a downstreamObserver
to an upstreamObserver
.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Interface to composeObservable
s.Provides a mechanism for receiving push-based notifications.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.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).TheSingle
class implements the Reactive Pattern for a single value response.Convenience interface and callback used by theSingle.to(io.reactivex.rxjava3.core.SingleConverter<T, ? extends R>)
operator to turn aSingle
into another value fluently.Abstraction over an RxJavaSingleObserver
that allows associating a resource with it.Provides a mechanism for receiving push-based notification of a single value or an error.A functional interface that has asubscribe()
method that receives aSingleEmitter
instance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstreamSingleObserver
to an upstreamSingleObserver
.Represents a basicSingle
source base interface, consumable via anSingleObserver
.Interface to composeSingle
s. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.flowablesClassDescriptionThe
Flowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.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.disposablesClassDescriptionProvides a mechanism for receiving push-based notification of a valueless completion or an error.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Provides a mechanism for receiving push-based notifications.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.functionsClassDescriptionRepresents the reactive signal types:
onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).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.fuseableClassDescriptionRepresents a basic
Completable
source base interface, consumable via anCompletableObserver
.TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.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.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.jdk8ClassDescriptionThe
Completable
class represents a deferred computation without any value but only indication for completion or exception.Provides a mechanism for receiving push-based notification of a valueless completion or an error.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.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.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Provides a mechanism for receiving push-based notifications.TheSingle
class implements the Reactive Pattern for a single value response.Provides a mechanism for receiving push-based notification of a single value or an error.Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.observersClassDescriptionProvides a mechanism for receiving push-based notification of a valueless completion or an error.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Provides a mechanism for receiving push-based notifications.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.completableClassDescriptionThe
Completable
class represents a deferred computation without any value but only indication for completion or exception.Abstraction over an RxJavaCompletableObserver
that allows associating a resource with it.Provides a mechanism for receiving push-based notification of a valueless completion or an error.A functional interface that has asubscribe()
method that receives aCompletableEmitter
instance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstream observer to an upstream observer.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).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.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Provides a mechanism for receiving push-based notifications.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.TheSingle
class implements the Reactive Pattern for a single value response.Provides a mechanism for receiving push-based notification of a single value or an error.Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.flowableClassDescriptionOptions to deal with buffer overflow when using onBackpressureBuffer.Represents the options for applying backpressure to a source sequence.The
Completable
class represents a deferred computation without any value but only indication for completion or exception.Provides a mechanism for receiving push-based notification of a valueless completion or an error.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Abstraction over a Reactive StreamsSubscriber
that allows associating a resource with it and exposes the current number of downstream requested amount.A functional interface that has asubscribe()
method that receives aFlowableEmitter
instance that allows pushing events in a backpressure-safe and cancellation-safe manner.Interface to map/wrap a downstreamSubscriber
to an upstreamSubscriber
.TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Provides a mechanism for receiving push-based notifications.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.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).TheSingle
class implements the Reactive Pattern for a single value response.Provides a mechanism for receiving push-based notification of a single value or an error.Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.maybeClassDescriptionThe
Completable
class represents a deferred computation without any value but only indication for completion or exception.Provides a mechanism for receiving push-based notification of a valueless completion or an error.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Abstraction over an RxJavaMaybeObserver
that allows associating a resource with it.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.A functional interface that has asubscribe()
method that receives aMaybeEmitter
instance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstreamMaybeObserver
to an upstreamMaybeObserver
.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).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.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Provides a mechanism for receiving push-based notifications.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.TheSingle
class implements the Reactive Pattern for a single value response.Provides a mechanism for receiving push-based notification of a single value or an error.Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.mixedClassDescriptionThe
Completable
class represents a deferred computation without any value but only indication for completion or exception.Provides a mechanism for receiving push-based notification of a valueless completion or an error.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).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.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Provides a mechanism for receiving push-based notifications.Provides a mechanism for receiving push-based notification of a single value or an error.Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.observableClassDescriptionThe
Completable
class represents a deferred computation without any value but only indication for completion or exception.Provides a mechanism for receiving push-based notification of a valueless completion or an error.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).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.Abstraction over an RxJavaObserver
that allows associating a resource with it.A functional interface that has asubscribe()
method that receives anObservableEmitter
instance that allows pushing events in a cancellation-safe manner.Interface to map/wrap a downstreamObserver
to an upstreamObserver
.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Provides a mechanism for receiving push-based notifications.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.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).TheSingle
class implements the Reactive Pattern for a single value response.Provides a mechanism for receiving push-based notification of a single value or an error.Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.parallelClassDescriptionThe
Flowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.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.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.singleClassDescriptionThe
Completable
class represents a deferred computation without any value but only indication for completion or exception.Provides a mechanism for receiving push-based notification of a valueless completion or an error.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.Represents the reactive signal types:onNext
,onError
andonComplete
and holds their parameter values (a value, aThrowable
, nothing).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.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Provides a mechanism for receiving push-based notifications.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.TheSingle
class implements the Reactive Pattern for a single value response.Abstraction over an RxJavaSingleObserver
that allows associating a resource with it.Provides a mechanism for receiving push-based notification of a single value or an error.A functional interface that has asubscribe()
method that receives aSingleEmitter
instance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstreamSingleObserver
to an upstreamSingleObserver
.Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.schedulersClassDescriptionThe
Completable
class represents a deferred computation without any value but only indication for completion or exception.Provides a mechanism for receiving push-based notification of a valueless completion or an error.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.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.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.subscribersClassDescription
-
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.utilClassDescriptionProvides a mechanism for receiving push-based notification of a valueless completion or an error.Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Provides a mechanism for receiving push-based notifications.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.observablesClassDescriptionThe
Observable
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.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.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.observersClassDescriptionProvides a mechanism for receiving push-based notification of a valueless completion or an error.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Provides a mechanism for receiving push-based notifications.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.operatorsClassDescription
-
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.parallelClassDescriptionThe
Flowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.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.pluginsClassDescriptionThe
Completable
class represents a deferred computation without any value but only indication for completion or exception.Provides a mechanism for receiving push-based notification of a valueless completion or an error.TheFlowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.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.Provides a mechanism for receiving push-based notifications.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.TheSingle
class implements the Reactive Pattern for a single value response.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.processorsClassDescriptionThe
Flowable
class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.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.schedulersClassDescriptionA
Scheduler
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.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.subjectsClassDescriptionThe
Completable
class represents a deferred computation without any value but only indication for completion or exception.Provides a mechanism for receiving push-based notification of a valueless completion or an error.Represents a basicCompletable
source base interface, consumable via anCompletableObserver
.TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.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.Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.Provides a mechanism for receiving push-based notifications.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.TheSingle
class implements the Reactive Pattern for a single value response.Provides a mechanism for receiving push-based notification of a single value or an error.Represents a basicSingle
source base interface, consumable via anSingleObserver
. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.subscribersClassDescription