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.

Mixin templates

SimpleObserverImpl
mixintemplate SimpleObserverImpl(TObserver, E)
Undocumented in source.

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.

Meta