Function TestWaitBuffer_WaitForNth_Blocks

testutil/wait_buffer_test.go:169–192

(t *testing.T)

}

func TestWaitBuffer_WaitForNth_Blocks(t *testing.T) {
	t.Parallel()
	ctx := testutil.Context(t, testutil.WaitShort)

	wb := testutil.NewWaitBuffer()
	_, err := wb.Write([]byte("Foo "))
	require.NoError(t, err)

	// First occurrence is already present, but we want two.
	done := make(chan struct{})
	go func() {
		defer close(done)
		_ = wb.WaitForNth(ctx, "Foo", 2)
	}()

	_, err = wb.Write([]byte("Bar Foo"))
	require.NoError(t, err)

	select {
	case <-done:
	case <-ctx.Done():
		t.Fatal("WaitForNth did not unblock after second occurrence")
	}
}

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