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()
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.

Interfaces

Observable
interface Observable(E)

Wrapper for Observable objects.

Templates

isObservable
template isObservable(T, E)

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