A 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
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 subscribed
Observers and terminal events to current
Replays events (in a configurable bounded or unbounded manner) to current and late
Represents a hot Single-like source and consumer of events similar to Subjects.
A Subject that queues up events until a single
Observer subscribes to it, replays
those events to it until the
Observer catches up and then switches to relaying events live to
Observer until this
UnicastSubject terminates or the
Available subject classes with their respective base classes and consumer interfaces:
The backpressure-aware variants of the
Subject class are called
Processors and reside in the