rx.subject

This module defines the Subject and some implements.

Members

Classes

AsyncSubject
class AsyncSubject(E)
BehaviorSubject
class BehaviorSubject(E)
ReplaySubject
class ReplaySubject(E)
SubjectObject
class SubjectObject(E)

Represents an object that is both an observable sequence as well as an observer. Each notification is broadcasted to all subscribed observers.

Functions

asBehaviorSubject
auto asBehaviorSubject(auto ref TObservable observable)
asReplaySubject
auto asReplaySubject(auto ref TObservable observable, size_t bufferSize)

Interfaces

Subject
interface Subject(E)

Represents an object that is both an observable sequence as well as an observer.