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,MaybeandCompletable; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.flowables Classes supporting the Flowable base reactive class:ConnectableFlowableandGroupedFlowable.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:ConnectableObservableandGroupedObservable.io.reactivex.rxjava3.observers Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and theTestObserverthat 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 withFlowablesequences in parallel.io.reactivex.rxjava3.plugins Contains the central plugin handlerRxJavaPluginsclass 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 theFlowableProcessorclass, the Reactive StreamsProcessorinterface 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 ofSchedulersproviding methods for retrieving the standard scheduler instances, theTestSchedulerfor testing flows with scheduling in a controlled manner and the classTimedthat 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 theTestSubscriberthat 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 TheCompletableclass 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 RxJavaCompletableObserverthat 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 aCompletableEmitterinstance 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 basicCompletablesource base interface, consumable via anCompletableObserver.CompletableTransformer Convenience interface and callback used by the compose operator to turn aCompletableinto anotherCompletablefluently.Emitter Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern 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 aFlowableinto another value fluently.FlowableEmitter Abstraction over a Reactive StreamsSubscriberthat 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 aFlowableEmitterinstance that allows pushing events in a backpressure-safe and cancellation-safe manner.FlowableOperator Interface to map/wrap a downstreamSubscriberto an upstreamSubscriber.FlowableSubscriber FlowableTransformer Interface to composeFlowables.Maybe TheMaybeclass 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 aMaybeinto another value fluently.MaybeEmitter Abstraction over an RxJavaMaybeObserverthat 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 aMaybeEmitterinstance that allows pushing an event in a cancellation-safe manner.MaybeOperator Interface to map/wrap a downstreamMaybeObserverto an upstreamMaybeObserver.MaybeSource Represents a basicMaybesource base interface, consumable via anMaybeObserver.MaybeTransformer Interface to composeMaybes.Notification Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).Observable 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.ObservableConverter Convenience interface and callback used by theObservable.to(io.reactivex.rxjava3.core.ObservableConverter<T, ? extends R>)operator to turn anObservableinto another value fluently.ObservableEmitter Abstraction over an RxJavaObserverthat allows associating a resource with it.ObservableOnSubscribe A functional interface that has asubscribe()method that receives anObservableEmitterinstance that allows pushing events in a cancellation-safe manner.ObservableOperator Interface to map/wrap a downstreamObserverto an upstreamObserver.ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.ObservableTransformer Interface to composeObservables.Observer Provides a mechanism for receiving push-based notifications.Scheduler 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.Scheduler.Worker 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).Single TheSingleclass 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 aSingleinto another value fluently.SingleEmitter Abstraction over an RxJavaSingleObserverthat 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 aSingleEmitterinstance that allows pushing an event in a cancellation-safe manner.SingleOperator Interface to map/wrap a downstreamSingleObserverto an upstreamSingleObserver.SingleSource Represents a basicSinglesource base interface, consumable via anSingleObserver.SingleTransformer Interface to composeSingles. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.flowables Class Description Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Scheduler 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.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,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).Scheduler 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.fuseable Class Description CompletableSource Represents a basicCompletablesource base interface, consumable via anCompletableObserver.Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Maybe TheMaybeclass represents a deferred computation and emission of a single value, no value at all or an exception.MaybeSource Represents a basicMaybesource base interface, consumable via anMaybeObserver.Observable 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.ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.SingleSource Represents a basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.jdk8 Class Description Completable TheCompletableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Maybe TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Observable 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.ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Observer Provides a mechanism for receiving push-based notifications.Single TheSingleclass 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 basicSinglesource 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 TheCompletableclass represents a deferred computation without any value but only indication for completion or exception.CompletableEmitter Abstraction over an RxJavaCompletableObserverthat 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 aCompletableEmitterinstance 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 basicCompletablesource base interface, consumable via anCompletableObserver.Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Maybe TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Notification Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).Observable 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.ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Observer Provides a mechanism for receiving push-based notifications.Scheduler 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.Single TheSingleclass 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 basicSinglesource 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 TheCompletableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.Emitter Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableEmitter Abstraction over a Reactive StreamsSubscriberthat 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 aFlowableEmitterinstance that allows pushing events in a backpressure-safe and cancellation-safe manner.FlowableOperator Interface to map/wrap a downstreamSubscriberto an upstreamSubscriber.FlowableSubscriber Maybe TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Notification Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Observer Provides a mechanism for receiving push-based notifications.Scheduler 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.Scheduler.Worker 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).Single TheSingleclass 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.maybe Class Description Completable TheCompletableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Maybe TheMaybeclass represents a deferred computation and emission of a single value, no value at all or an exception.MaybeEmitter Abstraction over an RxJavaMaybeObserverthat 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 aMaybeEmitterinstance that allows pushing an event in a cancellation-safe manner.MaybeOperator Interface to map/wrap a downstreamMaybeObserverto an upstreamMaybeObserver.MaybeSource Represents a basicMaybesource base interface, consumable via anMaybeObserver.Notification Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).Observable 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.ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Observer Provides a mechanism for receiving push-based notifications.Scheduler 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.Single TheSingleclass 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.mixed Class Description Completable TheCompletableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern 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 basicMaybesource base interface, consumable via anMaybeObserver.Notification Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).Observable 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.ObservableSource Represents a basic, non-backpressuredObservablesource 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.observable Class Description Completable TheCompletableclass 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 basicCompletablesource 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 TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Notification Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).Observable 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.ObservableEmitter Abstraction over an RxJavaObserverthat allows associating a resource with it.ObservableOnSubscribe A functional interface that has asubscribe()method that receives anObservableEmitterinstance that allows pushing events in a cancellation-safe manner.ObservableOperator Interface to map/wrap a downstreamObserverto an upstreamObserver.ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Observer Provides a mechanism for receiving push-based notifications.Scheduler 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.Scheduler.Worker 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).Single TheSingleclass 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.operators.parallel Class Description Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Scheduler 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.Scheduler.Worker 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.single Class Description Completable TheCompletableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Maybe TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Notification Represents the reactive signal types:onNext,onErrorandonCompleteand holds their parameter values (a value, aThrowable, nothing).Observable 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.ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Observer Provides a mechanism for receiving push-based notifications.Scheduler 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.Single TheSingleclass implements the Reactive Pattern for a single value response.SingleEmitter Abstraction over an RxJavaSingleObserverthat 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 aSingleEmitterinstance that allows pushing an event in a cancellation-safe manner.SingleOperator Interface to map/wrap a downstreamSingleObserverto an upstreamSingleObserver.SingleSource Represents a basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.internal.schedulers Class Description Completable TheCompletableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.Flowable TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Scheduler 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.Scheduler.Worker 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.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 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.ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Scheduler 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.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 TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Scheduler 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.plugins Class Description Completable TheCompletableclass 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 TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.Maybe TheMaybeclass 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 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.Observer Provides a mechanism for receiving push-based notifications.Scheduler 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.Single TheSingleclass 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 TheFlowableclass that implements the Reactive StreamsPublisherPattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.FlowableSubscriber Scheduler 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.schedulers Class Description Scheduler 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.Scheduler.Worker 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.subjects Class Description Completable TheCompletableclass 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 basicCompletablesource base interface, consumable via anCompletableObserver.Maybe TheMaybeclass 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 basicMaybesource base interface, consumable via anMaybeObserver.Observable 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.ObservableSource Represents a basic, non-backpressuredObservablesource base interface, consumable via anObserver.Observer Provides a mechanism for receiving push-based notifications.Scheduler 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.Single TheSingleclass 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 basicSinglesource base interface, consumable via anSingleObserver. -
Classes in io.reactivex.rxjava3.core used by io.reactivex.rxjava3.subscribers Class Description FlowableSubscriber