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
Completableclass 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 RxJavaCompletableObserverthat 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 aCompletableEmitterinstance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstream observer to an upstream observer.Represents a basicCompletablesource base interface, consumable via anCompletableObserver.Convenience interface and callback used by the compose operator to turn aCompletableinto anotherCompletablefluently.Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).TheFlowableclass that implements the Reactive StreamsPublisherPattern 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 aFlowableinto another value fluently.Abstraction over a Reactive StreamsSubscriberthat allows associating a resource with it and exposes the current number of downstream requested amount.A functional interface that has asubscribe()method that receives aFlowableEmitterinstance that allows pushing events in a backpressure-safe and cancellation-safe manner.Interface to map/wrap a downstreamSubscriberto an upstreamSubscriber.Interface to composeFlowables.TheMaybeclass 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 aMaybeinto another value fluently.Abstraction over an RxJavaMaybeObserverthat 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 aMaybeEmitterinstance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstreamMaybeObserverto an upstreamMaybeObserver.Represents a basicMaybesource base interface, consumable via anMaybeObserver.Interface to composeMaybes.Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).TheObservableclass 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 anObservableinto another value fluently.Abstraction over an RxJavaObserverthat allows associating a resource with it.A functional interface that has asubscribe()method that receives anObservableEmitterinstance that allows pushing events in a cancellation-safe manner.Interface to map/wrap a downstreamObserverto an upstreamObserver.Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Interface to composeObservables.Provides a mechanism for receiving push-based notifications.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Represents an isolated, sequential worker of a parent Scheduler for executingRunnabletasks on an underlying task-execution scheme (such as custom Threads, event loop,Executoror Actor system).TheSingleclass 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 aSingleinto another value fluently.Abstraction over an RxJavaSingleObserverthat 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 aSingleEmitterinstance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstreamSingleObserverto an upstreamSingleObserver.Represents a basicSinglesource base interface, consumable via anSingleObserver.Interface to composeSingles. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.flowablesClassDescriptionThe
Flowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror 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,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror 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
Completablesource base interface, consumable via anCompletableObserver.TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybeclass represents a deferred computation and emission of a single value, no value at all or an exception.Represents a basicMaybesource base interface, consumable via anMaybeObserver.TheObservableclass 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-backpressuredObservablesource base interface, consumable via anObserver.Represents a basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.jdk8ClassDescriptionThe
Completableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.TheObservableclass 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-backpressuredObservablesource base interface, consumable via anObserver.Provides a mechanism for receiving push-based notifications.TheSingleclass 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 basicSinglesource 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
Completableclass represents a deferred computation without any value but only indication for completion or exception.Abstraction over an RxJavaCompletableObserverthat 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 aCompletableEmitterinstance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstream observer to an upstream observer.Represents a basicCompletablesource base interface, consumable via anCompletableObserver.TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).TheObservableclass 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-backpressuredObservablesource base interface, consumable via anObserver.Provides a mechanism for receiving push-based notifications.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.TheSingleclass 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 basicSinglesource 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
Completableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Abstraction over a Reactive StreamsSubscriberthat allows associating a resource with it and exposes the current number of downstream requested amount.A functional interface that has asubscribe()method that receives aFlowableEmitterinstance that allows pushing events in a backpressure-safe and cancellation-safe manner.Interface to map/wrap a downstreamSubscriberto an upstreamSubscriber.TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Provides a mechanism for receiving push-based notifications.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Represents an isolated, sequential worker of a parent Scheduler for executingRunnabletasks on an underlying task-execution scheme (such as custom Threads, event loop,Executoror Actor system).TheSingleclass 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.maybeClassDescriptionThe
Completableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybeclass represents a deferred computation and emission of a single value, no value at all or an exception.Abstraction over an RxJavaMaybeObserverthat 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 aMaybeEmitterinstance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstreamMaybeObserverto an upstreamMaybeObserver.Represents a basicMaybesource base interface, consumable via anMaybeObserver.Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).TheObservableclass 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-backpressuredObservablesource base interface, consumable via anObserver.Provides a mechanism for receiving push-based notifications.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.TheSingleclass 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.mixedClassDescriptionThe
Completableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.TheFlowableclass that implements the Reactive StreamsPublisherPattern 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 basicMaybesource base interface, consumable via anMaybeObserver.Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).TheObservableclass 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-backpressuredObservablesource 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.observableClassDescriptionThe
Completableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).TheObservableclass 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 RxJavaObserverthat allows associating a resource with it.A functional interface that has asubscribe()method that receives anObservableEmitterinstance that allows pushing events in a cancellation-safe manner.Interface to map/wrap a downstreamObserverto an upstreamObserver.Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Provides a mechanism for receiving push-based notifications.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Represents an isolated, sequential worker of a parent Scheduler for executingRunnabletasks on an underlying task-execution scheme (such as custom Threads, event loop,Executoror Actor system).TheSingleclass 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.parallelClassDescriptionThe
Flowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Represents an isolated, sequential worker of a parent Scheduler for executingRunnabletasks on an underlying task-execution scheme (such as custom Threads, event loop,Executoror Actor system). -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.singleClassDescriptionThe
Completableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).TheObservableclass 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-backpressuredObservablesource base interface, consumable via anObserver.Provides a mechanism for receiving push-based notifications.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.TheSingleclass implements the Reactive Pattern for a single value response.Abstraction over an RxJavaSingleObserverthat 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 aSingleEmitterinstance that allows pushing an event in a cancellation-safe manner.Interface to map/wrap a downstreamSingleObserverto an upstreamSingleObserver.Represents a basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.schedulersClassDescriptionThe
Completableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Represents an isolated, sequential worker of a parent Scheduler for executingRunnabletasks on an underlying task-execution scheme (such as custom Threads, event loop,Executoror 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
Observableclass 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-backpressuredObservablesource base interface, consumable via anObserver.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror 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
Flowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror 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
Completableclass 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.TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.TheMaybeclass 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.TheObservableclass 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.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.TheSingleclass 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
Flowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror 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
Scheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.Represents an isolated, sequential worker of a parent Scheduler for executingRunnabletasks on an underlying task-execution scheme (such as custom Threads, event loop,Executoror Actor system). -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.subjectsClassDescriptionThe
Completableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.TheObservableclass 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-backpressuredObservablesource base interface, consumable via anObserver.Provides a mechanism for receiving push-based notifications.AScheduleris an object that specifies an API for scheduling units of work provided in the form ofRunnables 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,Executoror Actor system) with some uniform properties and guarantees regardless of the particular underlying scheme.TheSingleclass 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.subscribersClassDescription