concurrency.stream.take

Undocumented in source.

Members

Functions

take auto take(Stream stream, size_t n): takes the first n values from a stream or until cancelled

Structs

TakeReceiver struct TakeReceiver(Receiver, Value): Undocumented in source.

Templates

TakeOp template TakeOp(Stream): Undocumented in source.

Meta

Source

See Source File