pub fn awaitMany(s: *S, buffer: []U, min: usize) Cancelable!usize s: *Sbuffer: []Umin: usizeCanceledCaller has requested the async operation to stop.
1608
1609
1610
1611
1612
1613 pub fn awaitMany(s: *S, buffer: []U, min: usize) Cancelable!usize {
return s.queue.get(s.io, buffer, min) catch |err| switch (err) {
error.Canceled => |e| return e,
error.Closed => unreachable,
};
}
Blocks until at least
minnumber of results have been copied intobuffer.Asserts that
buffer.len >= min.It is legal to call
asyncandconcurrentafter this.Threadsafe.