Annotations for indicating operator behavior, API stability (@Experimental and @Beta) and nullability indicators (Nullable and NonNull).

Default implementations for Disposable-based resource management (Disposable container types) and utility classes to construct Disposables from callbacks and other types.

Classes supporting the Flowable base reactive class: io.reactivex.rxjava3.flowables.ConnectableFlowable and io.reactivex.rxjava3.flowables.GroupedFlowable.

Base interfaces and types for supporting operator-fusion.

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.

Contains the base type io.reactivex.rxjava3.parallel.ParallelFlowable, a sub-DSL for working with io.reactivex.rxjava3.core.Flowable sequences in parallel.

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.

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.