AsyncSubject |
A Subject that emits the very last value followed by a completion event or the received error to Observers.
|
AsyncSubject.AsyncDisposable |
|
BehaviorSubject |
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed
Observer .
|
BehaviorSubject.BehaviorDisposable |
|
CompletableSubject |
Represents a hot Completable-like source and consumer of events similar to Subjects.
|
CompletableSubject.CompletableDisposable |
|
MaybeSubject |
Represents a hot Maybe-like source and consumer of events similar to Subjects.
|
MaybeSubject.MaybeDisposable |
|
PublishSubject |
A Subject that emits (multicasts) items to currently subscribed Observer s and terminal events to current
or late Observer s.
|
PublishSubject.PublishDisposable |
Wraps the actual subscriber, tracks its requests and makes cancellation
to remove itself from the current subscribers array.
|
ReplaySubject |
Replays events (in a configurable bounded or unbounded manner) to current and late Observer s.
|
ReplaySubject.Node |
|
ReplaySubject.ReplayBuffer |
Abstraction over a buffer that receives events and replays them to
individual Observers.
|
ReplaySubject.ReplayDisposable |
|
ReplaySubject.TimedNode |
|
SingleSubject |
Represents a hot Single-like source and consumer of events similar to Subjects.
|
SingleSubject.SingleDisposable |
|
Subject |
Represents an Observer and an Observable at the same time, allowing
multicasting events from a single source to multiple child Observer s.
|
UnicastSubject |
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
this single Observer until this UnicastSubject terminates or the Observer disposes.
|