concurrency.stream

Undocumented in source.

Modules

cron module concurrency.stream.cron: Undocumented in source.
cycle module concurrency.stream.cycle: Undocumented in source.
defer module concurrency.stream.defer: Undocumented in source.
filter module concurrency.stream.filter: Undocumented in source.
flatmapbase module concurrency.stream.flatmapbase: Undocumented in source.
flatmapconcat module concurrency.stream.flatmapconcat: Undocumented in source.
flatmaplatest module concurrency.stream.flatmaplatest: Undocumented in source.
sample module concurrency.stream.sample: Undocumented in source.
scan module concurrency.stream.scan: Undocumented in source.
slide module concurrency.stream.slide: Undocumented in source.
stream module concurrency.stream.stream: Undocumented in source.
take module concurrency.stream.take: Undocumented in source.
throttling module concurrency.stream.throttling: Undocumented in source.
tolist module concurrency.stream.tolist: Undocumented in source.
transform module concurrency.stream.transform: Undocumented in source.

concurrency.stream.stream public import concurrency.stream.stream;: Undocumented in source.

concurrency.stream.filter public import concurrency.stream.filter;: Undocumented in source.

concurrency.stream.take public import concurrency.stream.take;: Undocumented in source.

concurrency.stream.transform public import concurrency.stream.transform;: Undocumented in source.

concurrency.stream.scan public import concurrency.stream.scan;: Undocumented in source.

concurrency.stream.sample public import concurrency.stream.sample;: Undocumented in source.

concurrency.stream.tolist public import concurrency.stream.tolist;: Undocumented in source.

concurrency.stream.slide public import concurrency.stream.slide;: Undocumented in source.

concurrency.stream.throttling public import concurrency.stream.throttling;: Undocumented in source.

concurrency.stream.cycle public import concurrency.stream.cycle;: Undocumented in source.

concurrency.stream.cron public import concurrency.stream.cron;: Undocumented in source.

concurrency.stream.defer auto defer(Fun fun) via public import concurrency.stream.defer;: Undocumented in source.

concurrency.stream.flatmapconcat public import concurrency.stream.flatmapconcat;: Undocumented in source.

concurrency.stream.flatmaplatest public import concurrency.stream.flatmaplatest;: Undocumented in source.

arrayStream auto arrayStream(T[] arr): Stream that emits each value from the array or until cancelled
doneStream auto doneStream(): Undocumented in source. Be warned that the author may not have intended to support it.
errorStream auto errorStream(Exception e): Undocumented in source. Be warned that the author may not have intended to support it.
infiniteStream auto infiniteStream(T t): Stream that emit the same value until cancelled
intervalStream auto intervalStream(Duration duration, bool emitAtStart): Undocumented in source. Be warned that the author may not have intended to support it.
iotaStream auto iotaStream(T start, T end): Stream that emits from start..end or until cancelled
sharedStream auto sharedStream(): A SharedStream is used for broadcasting values to zero or more receivers. Receivers can be added and removed at any time. The stream itself never completes, so receivers should themselves terminate their connection.
via auto via(Stream stream, Sender sender): Undocumented in source. Be warned that the author may not have intended to support it.