concurrency v5.0.3 (2023-04-12T14:20:47Z)
Dub
Repo
take
concurrency
stream
take
takes the first n values from a stream or until cancelled
auto
take
(
Stream
)
(
Stream
stream
,
size_t
n
)
if
(
models
!(
Stream
,
isStream
)
)
Meta
Source
See Implementation
concurrency
stream
take
functions
take
structs
TakeReceiver
templates
TakeOp
takes the first n values from a stream or until cancelled