Namespace RxSharp.Subjects

Classes

AsyncSubject<T>

A Subject<T> that only emits its last nexted value, and only upon completion. If it errors instead, no value is ever emitted to any subscriber, regardless of what was nexted beforehand. Mirrors rxjs's AsyncSubject.

BehaviorSubject<T>

A Subject<T> that requires an initial value and synchronously replays its current value to every new subscriber. Mirrors rxjs's BehaviorSubject.

ReplaySubject<T>

A Subject<T> that buffers emitted values and replays them to new subscribers before they start receiving live values. Mirrors rxjs's ReplaySubject.

Subject<T>

A multicast IObservable<T> that is also an IObserver<T>: every value/error/completion pushed into it via the IObserver<T> methods is forwarded to every observer currently subscribed at that moment. Unlike Observable<T>, it is implemented directly against the BCL interfaces rather than by subclassing Observable<T> — same shape as rxjs's own Subject.