- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for NewCond (0.04 sec)
-
internal/ringbuffer/ring_buffer.go
// This setting should be called before any Read or Write operation or after a Reset. func (r *RingBuffer) SetBlocking(block bool) *RingBuffer { r.block = block if block { r.readCond = sync.NewCond(&r.mu) r.writeCond = sync.NewCond(&r.mu) } return r } // WithCancel sets a context to cancel the ring buffer. // When the context is canceled, the ring buffer will be closed with the context error.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0)