Function TestWaitBuffer_WaitFor_ContextExpired

testutil/wait_buffer_test.go:49–58

(t *testing.T)

}

func TestWaitBuffer_WaitFor_ContextExpired(t *testing.T) {
	t.Parallel()

	ctx, cancel := context.WithCancel(context.Background())
	cancel() // Already expired.

	wb := testutil.NewWaitBuffer()
	err := wb.WaitFor(ctx, "never")
	require.ErrorIs(t, err, context.Canceled)
}

func TestWaitBuffer_WaitFor_MultipleWrites(t *testing.T) {
	t.Parallel()