Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for NewCond (0.03 sec)

  1. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.3K bytes
    - Viewed (0)
Back to top