Skip navigation links

Package io.reactivex.processors

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.

See: Description

Package io.reactivex.processors Description

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.

Available processor implementations:

The non-backpressured variants of the FlowableProcessor class are called Subjects and reside in the io.reactivex.subjects package.

See Also:
io.reactivex.subjects
Skip navigation links