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