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
Observer
s and terminal events to current or lateObserver
s.Represents anObserver
and anObservable
at the same time, allowing multicasting events from a single source to multiple childObserver
s.A Subject that queues up events until a singleObserver
subscribes to it, replays those events to it until theObserver
catches up and then switches to relaying events live to this singleObserver
until thisUnicastSubject
terminates or theObserver
disposes. -
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 subscribedObserver
s and terminal events to current or lateObserver
s.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 lateObserver
s.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 anObserver
and anObservable
at the same time, allowing multicasting events from a single source to multiple childObserver
s.A Subject that queues up events until a singleObserver
subscribes to it, replays those events to it until theObserver
catches up and then switches to relaying events live to this singleObserver
until thisUnicastSubject
terminates or theObserver
disposes.