concurrency.stream.stream

Undocumented in source.

Members

Classes

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

Enums

isStream eponymoustemplate isStream(T): Undocumented in source.

Functions

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

Interfaces

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

Templates

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

Meta

Source

See Source File