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.
  • Class
    Description
    Options 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 the Completable.to(io.reactivex.rxjava3.core.CompletableConverter<? extends R>) operator to turn a Completable into another value fluently.
    Abstraction over an RxJava CompletableObserver 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 a subscribe() method that receives a CompletableEmitter instance that allows pushing an event in a cancellation-safe manner.
    Interface to map/wrap a downstream observer to an upstream observer.
    Represents a basic Completable source base interface, consumable via an CompletableObserver.
    Convenience interface and callback used by the compose operator to turn a Completable into another Completable fluently.
    Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    Convenience interface and callback used by the Flowable.to(io.reactivex.rxjava3.core.FlowableConverter<T, ? extends R>) operator to turn a Flowable into another value fluently.
    Abstraction over a Reactive Streams Subscriber that allows associating a resource with it and exposes the current number of downstream requested amount.
    A functional interface that has a subscribe() method that receives a FlowableEmitter instance that allows pushing events in a backpressure-safe and cancellation-safe manner.
    Interface to map/wrap a downstream Subscriber to an upstream Subscriber.
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    Interface to compose Flowables.
    The Maybe class represents a deferred computation and emission of a single value, no value at all or an exception.
    Convenience interface and callback used by the Maybe.to(io.reactivex.rxjava3.core.MaybeConverter<T, ? extends R>) operator to turn a Maybe into another value fluently.
    Abstraction over an RxJava MaybeObserver 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 a subscribe() method that receives a MaybeEmitter instance that allows pushing an event in a cancellation-safe manner.
    Interface to map/wrap a downstream MaybeObserver to an upstream MaybeObserver.
    Represents a basic Maybe source base interface, consumable via an MaybeObserver.
    Interface to compose Maybes.
    Represents the reactive signal types: onNext, onError and onComplete and holds their parameter values (a value, a Throwable, nothing).
    The 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.
    Convenience interface and callback used by the Observable.to(io.reactivex.rxjava3.core.ObservableConverter<T, ? extends R>) operator to turn an Observable into another value fluently.
    Abstraction over an RxJava Observer that allows associating a resource with it.
    A functional interface that has a subscribe() method that receives an ObservableEmitter instance that allows pushing events in a cancellation-safe manner.
    Interface to map/wrap a downstream Observer to an upstream Observer.
    Represents a basic, non-backpressured Observable source base interface, consumable via an Observer.
    Interface to compose Observables.
    Provides a mechanism for receiving push-based notifications.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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 executing Runnable tasks on an underlying task-execution scheme (such as custom Threads, event loop, Executor or Actor system).
    The Single class implements the Reactive Pattern for a single value response.
    Convenience interface and callback used by the Single.to(io.reactivex.rxjava3.core.SingleConverter<T, ? extends R>) operator to turn a Single into another value fluently.
    Abstraction over an RxJava SingleObserver 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 a subscribe() method that receives a SingleEmitter instance that allows pushing an event in a cancellation-safe manner.
    Interface to map/wrap a downstream SingleObserver to an upstream SingleObserver.
    Represents a basic Single source base interface, consumable via an SingleObserver.
    Interface to compose Singles.
  • Class
    Description
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
  • Class
    Description
    Provides 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.
  • Class
    Description
    Represents the reactive signal types: onNext, onError and onComplete and holds their parameter values (a value, a Throwable, nothing).
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
  • Class
    Description
    Represents a basic Completable source base interface, consumable via an CompletableObserver.
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    The Maybe class represents a deferred computation and emission of a single value, no value at all or an exception.
    Represents a basic Maybe source base interface, consumable via an MaybeObserver.
    The 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-backpressured Observable source base interface, consumable via an Observer.
    Represents a basic Single source base interface, consumable via an SingleObserver.
  • Class
    Description
    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 basic Completable source base interface, consumable via an CompletableObserver.
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    The Maybe 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 basic Maybe source base interface, consumable via an MaybeObserver.
    The 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-backpressured Observable source base interface, consumable via an Observer.
    Provides a mechanism for receiving push-based notifications.
    The Single 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 basic Single source base interface, consumable via an SingleObserver.
  • Class
    Description
    Provides 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.
  • Class
    Description
    The Completable class represents a deferred computation without any value but only indication for completion or exception.
    Abstraction over an RxJava CompletableObserver 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 a subscribe() method that receives a CompletableEmitter instance that allows pushing an event in a cancellation-safe manner.
    Interface to map/wrap a downstream observer to an upstream observer.
    Represents a basic Completable source base interface, consumable via an CompletableObserver.
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    The Maybe 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 basic Maybe source base interface, consumable via an MaybeObserver.
    Represents the reactive signal types: onNext, onError and onComplete and holds their parameter values (a value, a Throwable, nothing).
    The 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-backpressured Observable source base interface, consumable via an Observer.
    Provides a mechanism for receiving push-based notifications.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
    The Single 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 basic Single source base interface, consumable via an SingleObserver.
  • Class
    Description
    Options 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 basic Completable source base interface, consumable via an CompletableObserver.
    Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    Abstraction over a Reactive Streams Subscriber that allows associating a resource with it and exposes the current number of downstream requested amount.
    A functional interface that has a subscribe() method that receives a FlowableEmitter instance that allows pushing events in a backpressure-safe and cancellation-safe manner.
    Interface to map/wrap a downstream Subscriber to an upstream Subscriber.
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    The Maybe 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 basic Maybe source base interface, consumable via an MaybeObserver.
    Represents the reactive signal types: onNext, onError and onComplete and holds their parameter values (a value, a Throwable, nothing).
    Represents a basic, non-backpressured Observable source base interface, consumable via an Observer.
    Provides a mechanism for receiving push-based notifications.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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 executing Runnable tasks on an underlying task-execution scheme (such as custom Threads, event loop, Executor or Actor system).
    The Single 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 basic Single source base interface, consumable via an SingleObserver.
  • Class
    Description
    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 basic Completable source base interface, consumable via an CompletableObserver.
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    The Maybe class represents a deferred computation and emission of a single value, no value at all or an exception.
    Abstraction over an RxJava MaybeObserver 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 a subscribe() method that receives a MaybeEmitter instance that allows pushing an event in a cancellation-safe manner.
    Interface to map/wrap a downstream MaybeObserver to an upstream MaybeObserver.
    Represents a basic Maybe source base interface, consumable via an MaybeObserver.
    Represents the reactive signal types: onNext, onError and onComplete and holds their parameter values (a value, a Throwable, nothing).
    The 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-backpressured Observable source base interface, consumable via an Observer.
    Provides a mechanism for receiving push-based notifications.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
    The Single 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 basic Single source base interface, consumable via an SingleObserver.
  • Class
    Description
    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 basic Completable source base interface, consumable via an CompletableObserver.
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    Provides a mechanism for receiving push-based notification of a single value, an error or completion without any value.
    Represents a basic Maybe source base interface, consumable via an MaybeObserver.
    Represents the reactive signal types: onNext, onError and onComplete and holds their parameter values (a value, a Throwable, nothing).
    The 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-backpressured Observable source base interface, consumable via an Observer.
    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 basic Single source base interface, consumable via an SingleObserver.
  • Class
    Description
    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 basic Completable source base interface, consumable via an CompletableObserver.
    Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    The Maybe 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 basic Maybe source base interface, consumable via an MaybeObserver.
    Represents the reactive signal types: onNext, onError and onComplete and holds their parameter values (a value, a Throwable, nothing).
    The 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.
    Abstraction over an RxJava Observer that allows associating a resource with it.
    A functional interface that has a subscribe() method that receives an ObservableEmitter instance that allows pushing events in a cancellation-safe manner.
    Interface to map/wrap a downstream Observer to an upstream Observer.
    Represents a basic, non-backpressured Observable source base interface, consumable via an Observer.
    Provides a mechanism for receiving push-based notifications.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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 executing Runnable tasks on an underlying task-execution scheme (such as custom Threads, event loop, Executor or Actor system).
    The Single 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 basic Single source base interface, consumable via an SingleObserver.
  • Class
    Description
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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 executing Runnable tasks on an underlying task-execution scheme (such as custom Threads, event loop, Executor or Actor system).
  • Class
    Description
    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 basic Completable source base interface, consumable via an CompletableObserver.
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    The Maybe 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 basic Maybe source base interface, consumable via an MaybeObserver.
    Represents the reactive signal types: onNext, onError and onComplete and holds their parameter values (a value, a Throwable, nothing).
    The 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-backpressured Observable source base interface, consumable via an Observer.
    Provides a mechanism for receiving push-based notifications.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
    The Single class implements the Reactive Pattern for a single value response.
    Abstraction over an RxJava SingleObserver 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 a subscribe() method that receives a SingleEmitter instance that allows pushing an event in a cancellation-safe manner.
    Interface to map/wrap a downstream SingleObserver to an upstream SingleObserver.
    Represents a basic Single source base interface, consumable via an SingleObserver.
  • Class
    Description
    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 basic Completable source base interface, consumable via an CompletableObserver.
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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 executing Runnable tasks on an underlying task-execution scheme (such as custom Threads, event loop, Executor or Actor system).
  • Class
    Description
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
  • Class
    Description
    Provides 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).
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    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.
  • Class
    Description
    The 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-backpressured Observable source base interface, consumable via an Observer.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
  • Class
    Description
    Provides 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.
  • Class
    Description
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
  • Class
    Description
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
  • Class
    Description
    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.
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    The Maybe 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.
    The 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.
    Provides a mechanism for receiving push-based notifications.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
    The Single 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.
  • Class
    Description
    The Flowable class that implements the Reactive Streams Publisher Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
  • Class
    Description
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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 executing Runnable tasks on an underlying task-execution scheme (such as custom Threads, event loop, Executor or Actor system).
  • Class
    Description
    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 basic Completable source base interface, consumable via an CompletableObserver.
    The Maybe 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 basic Maybe source base interface, consumable via an MaybeObserver.
    The 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-backpressured Observable source base interface, consumable via an Observer.
    Provides a mechanism for receiving push-based notifications.
    A Scheduler is an object that specifies an API for scheduling units of work provided in the form of Runnables 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.
    The Single 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 basic Single source base interface, consumable via an SingleObserver.
  • Class
    Description
    Represents a Reactive-Streams inspired Subscriber that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.