Uses of Package
io.reactivex.rxjava3.subjects
Packages that use io.reactivex.rxjava3.subjects
Package
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.
-
Classes in io.reactivex.rxjava3.subjects used by io.reactivex.rxjava3.internal.operators.observableClassDescriptionA Subject that emits (multicasts) items to currently subscribed
Observers and terminal events to current or lateObservers.Represents anObserverand anObservableat the same time, allowing multicasting events from a single source to multiple childObservers.A Subject that queues up events until a singleObserversubscribes to it, replays those events to it until theObservercatches up and then switches to relaying events live to this singleObserveruntil thisUnicastSubjectterminates or theObserverdisposes. -
Classes in io.reactivex.rxjava3.subjects used by io.reactivex.rxjava3.subjectsClassDescriptionA Subject that emits the very last value followed by a completion event or the received error to Observers.Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed
Observer.Represents a hot Completable-like source and consumer of events similar to Subjects.Represents a hot Maybe-like source and consumer of events similar to Subjects.A Subject that emits (multicasts) items to currently subscribedObservers and terminal events to current or lateObservers.Wraps the actual subscriber, tracks its requests and makes cancellation to remove itself from the current subscribers array.Replays events (in a configurable bounded or unbounded manner) to current and lateObservers.Abstraction over a buffer that receives events and replays them to individual Observers.Represents a hot Single-like source and consumer of events similar to Subjects.Represents anObserverand anObservableat the same time, allowing multicasting events from a single source to multiple childObservers.A Subject that queues up events until a singleObserversubscribes to it, replays those events to it until theObservercatches up and then switches to relaying events live to this singleObserveruntil thisUnicastSubjectterminates or theObserverdisposes.