- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for TestRingBufferCloseErrorUnblocks (0.12 sec)
-
internal/ringbuffer/ring_buffer_test.go
t.Errorf("Read error: got %T, want testError1", err) } if _, err := rb.TryRead([]byte{0}); err != (testError1{}) { t.Errorf("Read error: got %T, want testError1", err) } } func TestRingBufferCloseErrorUnblocks(t *testing.T) { const sz = 100 rb := New(sz).SetBlocking(true) testCancel := func(fn func()) { t.Helper() defer timeout(5 * time.Second)() rb.Reset() done := make(chan struct{})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0)