- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for SetBlocking (0.07 sec)
-
internal/ringbuffer/ring_buffer_test.go
t.Fatalf("expect 16 abcd and 4 1234 but got %s. r.w=%d, r.r=%d", rb.Bytes(nil), rb.w, rb.r) } } func TestRingBuffer_WriteBlocking(t *testing.T) { rb := New(64).SetBlocking(true) // check empty or full if !rb.IsEmpty() { t.Fatalf("expect IsEmpty is true but got false") } if rb.IsFull() { t.Fatalf("expect IsFull is false but got true") } if rb.Length() != 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
size: size, } } // NewBuffer returns a new RingBuffer whose buffer is provided. func NewBuffer(b []byte) *RingBuffer { return &RingBuffer{ buf: b, size: len(b), } } // SetBlocking sets the blocking mode of the ring buffer. // If block is true, Read and Write will block when there is no data to read or no space to write. // If block is false, Read and Write will return ErrIsEmpty or ErrIsFull immediately.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0)