observe

Members

Aliases

CompletedFunc

alias CompletedFunc = void delegate()

Undocumented in source.

ErrorFunc

alias ErrorFunc = void delegate(Exception)

Undocumented in source.

observeRange

alias observeRange = observe

Undocumented in source.

Classes

BufferSample

class BufferSample(Src, Sampler)

Undocumented in source.

ConcatMap

class ConcatMap(T, alias func)

Undocumented in source.

FiberSubject

class FiberSubject(E)

Undocumented in source.

Fork

class Fork(E)

Undocumented in source.

ObservableRange

class ObservableRange(R)

Undocumented in source.

ObservableTimer

class ObservableTimer

Undocumented in source.

Observer

class Observer(E)

Undocumented in source.

Retry

class Retry(Obs)

Undocumented in source.

Subject

class Subject(E)

Undocumented in source.

Take

class Take(Obs)

Undocumented in source.

TakeUntil

class TakeUntil(Obs)

Undocumented in source.

Functions

array

auto array(Obs o)

Undocumented in source. Be warned that the author may not have intended to support it.

bufferSample

auto bufferSample(Src source, Sampler sampler)

Undocumented in source. Be warned that the author may not have intended to support it.

chain

Observer!(ElementType!ObsA) chain(ObsA a, ObsB b)

Undocumented in source. Be warned that the author may not have intended to support it.

fork

Fork!(ElementType!Obs) fork(Obs o, int legs)

Undocumented in source. Be warned that the author may not have intended to support it.

observe

ObservableRange!R observe(R r)

Undocumented in source. Be warned that the author may not have intended to support it.

retry

auto retry(Obs obs, int maxTries)

Undocumented in source. Be warned that the author may not have intended to support it.

take

auto take(Obs o, uint n)

Undocumented in source. Be warned that the author may not have intended to support it.

takeUntil

auto takeUntil(Obs a, int timeout)

Undocumented in source. Be warned that the author may not have intended to support it.

timer

auto timer(int delay, int period)

Undocumented in source. Be warned that the author may not have intended to support it.

zip

Observer!(Tuple!(ElementType!ObsA, ElementType!ObsB)) zip(ObsA a, ObsB b)

Undocumented in source. Be warned that the author may not have intended to support it.

Structs

ObservableTimerSubscription

struct ObservableTimerSubscription

Undocumented in source.

Subscription

struct Subscription(Observable)

Undocumented in source.

Templates

ElementType

template ElementType(R)

Undocumented in source.

concatMap

template concatMap(alias fun)

Undocumented in source.

filter

template filter(alias fun)

Undocumented in source.

filterError

template filterError(alias fun)

Undocumented in source.

foo

template foo(alias fun)

Undocumented in source.

isObservable

template isObservable(O)

Undocumented in source.

isSubject

template isSubject(S)

Undocumented in source.

map

template map(alias fun)

Undocumented in source.

retry

template retry(alias fun)

Undocumented in source.

tap

template tap(alias fun)

Undocumented in source.

tapError

template tapError(alias fun)

Undocumented in source.

• observe