rx.observable

This module defines the concept of Observable.

Members

Aliases

asObservable alias asObservable = from

Classes

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

Functions

defer auto defer(): Create observable by function that template parameter.
defer auto defer(TSubscribe subscribeImpl): Undocumented in source. Be warned that the author may not have intended to support it.
doSubscribe auto doSubscribe(TObservable observable, void delegate(E) doPut, void delegate() doCompleted, void delegate(Exception) doFailure)
auto doSubscribe(TObservable observable, void delegate(E) doPut, void delegate() doCompleted)
auto doSubscribe(TObservable observable, void delegate(E) doPut, void delegate(Exception) doFailure)
auto doSubscribe(TObservable observable)
auto doSubscribe(TObservable observable, TObserver observer): The helper for subscribe easier.
empty auto empty()
error auto error(Exception e)
from auto from(R input)
never auto never()

Interfaces

Observable interface Observable(E): Wrapper for Observable objects.

Templates

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.

Meta

Source

See Source File

rx modules