Function TestWaitBuffer_WaitFor_BackgroundGoroutine

testutil/wait_buffer_test.go:135–152

(t *testing.T)

}

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

	ctx, cancel := context.WithCancel(context.Background())
	cancel() // Expire immediately.

	wb := testutil.NewWaitBuffer()

	// WaitFor from a background goroutine should return the
	// context error rather than calling t.Fatal.
	done := make(chan error, 1)
	go func() {
		done <- wb.WaitFor(ctx, "never")
	}()

	err := <-done
	require.ErrorIs(t, err, context.Canceled)
}

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