- 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()
Undocumented in source. Be warned that the author may not have intended to support it.
- error
auto error(Exception e)
Undocumented in source. Be warned that the author may not have intended to support it.
- from
auto from(R input)
- never
auto never()
Undocumented in source. Be warned that the author may not have intended to support it.
This module defines the concept of Observable.