Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for NewCond (0.04 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top