pub fn getUncancelable(q: *TypeErasedQueue, io: Io, buffer: []u8, min: usize) QueueClosedError!usize
Same as get, except does not introduce a cancelation point.
get
For a description of cancelation and cancelation points, see Future.cancel.
Future.cancel
q: *TypeErasedQueue
io: Io
buffer: []u8
min: usize
Closed
2247 2248 2249 2250 2251 2252 2253 2254 2255 2256
pub fn getUncancelable(q: *TypeErasedQueue, io: Io, buffer: []u8, min: usize) QueueClosedError!usize { assert(buffer.len >= min); if (buffer.len == 0) return 0; q.mutex.lockUncancelable(io); defer q.mutex.unlock(io); return q.getLocked(io, buffer, min, true) catch |err| switch (err) { error.Canceled => unreachable, error.Closed => |e| return e, }; }
Same as
get, except does not introduce a cancelation point.For a description of cancelation and cancelation points, see
Future.cancel.