(t *testing.T)
| 35 | } |
| 36 | |
| 37 | func TestWaitBuffer_WaitFor_AlreadyPresent(t *testing.T) { |
| 38 | t.Parallel() |
| 39 | ctx := testutil.Context(t, testutil.WaitShort) |
| 40 | |
| 41 | wb := testutil.NewWaitBuffer() |
| 42 | _, err := wb.Write([]byte("already here")) |
| 43 | require.NoError(t, err) |
| 44 | |
| 45 | // Signal is already in the buffer; WaitFor returns immediately. |
| 46 | require.NoError(t, wb.WaitFor(ctx, "already")) |
| 47 | } |
| 48 | |
| 49 | func TestWaitBuffer_WaitFor_ContextExpired(t *testing.T) { |
| 50 | t.Parallel() |
nothing calls this directly
no test coverage detected