rx.observable

This module defines the concept of Observable.

Members

ObservableObject class ObservableObject(R, E): Class that implements Observable interface and wraps the subscribe method in virtual function.

defer auto defer(): Create observable by function that template parameter.
doSubscribe auto doSubscribe(auto ref TObservable observable, void delegate(E) doPut, void delegate() doCompleted, void delegate(Exception) doFailure)
auto doSubscribe(auto ref TObservable observable, void delegate(E) doPut, void delegate() doCompleted)
auto doSubscribe(auto ref TObservable observable, void delegate(E) doPut, void delegate(Exception) doFailure)
auto doSubscribe(auto ref TObservable observable)
auto doSubscribe(auto ref TObservable observable, auto ref TObserver observer): The helper for subscribe easier.
empty auto empty()
error auto error(auto ref Exception e)
from auto from(auto ref R input)
never auto never()

isObservable template isObservable(T, E)
template isObservable(TObservable): Tests if something is a Observable.
isSubscribable template isSubscribable(TObservable, TObserver): Test if the observer can subscribe to the observable.
observableObject template observableObject(E): Wraps subscribe method in virtual function.

rx modules