concurrency.stream.stream

Undocumented in source.

Members

StreamObjectImpl class StreamObjectImpl(Stream): A class extending from StreamObjectBase that wraps any Stream

checkStream void checkStream(): checks that T is a Stream
fromStreamOp auto fromStreamOp(Args args): Undocumented in source. Be warned that the author may not have intended to support it.
toStreamObject StreamObjectBase!(Stream.ElementType) toStreamObject(Stream stream): Converts any Stream to a polymorphic StreamObject

StreamObjectBase interface StreamObjectBase(T): A polymorphic stream with elements of type T

CollectDelegate template CollectDelegate(ElementType): A Stream is anything that has a .collect function that accepts a callable and returns a Sender. Once the Sender is connected and started the Stream will call the callable zero or more times before one of the three terminal functions of the Receiver is called.
SchedulerType template SchedulerType(Receiver): Undocumented in source.
StreamProperties template StreamProperties(Stream): Undocumented in source.
loopStream template loopStream(E): Helper to construct a Stream, useful if the Stream you are modeling has a blocking loop