Skip navigation links

Package 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.

See: Description

Package io.reactivex.rxjava3.subjects Description

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.

Available subject classes with their respective base classes and consumer interfaces:

Subject typeBase classConsumer interface
Subject
   AsyncSubject
   BehaviorSubject
   PublishSubject
   ReplaySubject
   UnicastSubject
Observable Observer
SingleSubject Single SingleObserver
MaybeSubject Maybe MaybeObserver
CompletableSubject Completable CompletableObserver

The backpressure-aware variants of the Subject class are called Processors and reside in the io.reactivex.processors package.

See Also:
io.reactivex.rxjava3.processors
Skip navigation links