rx.observer

This module defines the concept of Observer.

Members

Classes

CompositeObserver class CompositeObserver(E)
DoneObserver class DoneObserver(E)
NopObserver class NopObserver(E)
ObserverObject class ObserverObject(R, E...): Class that implements Observer interface and wraps the completed and failure method in virtual functions. This class extends the OutputRangeObject.

Functions

makeObserver auto makeObserver(void delegate(E) doPut, void delegate() doCompleted, void delegate(Exception) doFailure)
auto makeObserver(void delegate(E) doPut, void delegate() doCompleted)
auto makeObserver(void delegate(E) doPut, void delegate(Exception) doFailure): The helper for the own observer.

Interfaces

Observer interface Observer(E): Wraps completed and failure method in virtual function.

Templates

hasCompleted template hasCompleted(T): Tests if something has completed method.
hasFailure template hasFailure(T): Tests if something has failure method.
isObserver template isObserver(T, E): Tests if something is Observer.
observerObject template observerObject(E): Wraps subscribe method in virtual function.

rx modules