(t *testing.T)
| 152 | } |
| 153 | |
| 154 | func TestWaitBuffer_SequentialWaits(t *testing.T) { |
| 155 | t.Parallel() |
| 156 | ctx := testutil.Context(t, testutil.WaitShort) |
| 157 | |
| 158 | wb := testutil.NewWaitBuffer() |
| 159 | |
| 160 | _, err := wb.Write([]byte("first ")) |
| 161 | require.NoError(t, err) |
| 162 | require.NoError(t, wb.WaitFor(ctx, "first")) |
| 163 | |
| 164 | _, err = wb.Write([]byte("second")) |
| 165 | require.NoError(t, err) |
| 166 | require.NoError(t, wb.WaitFor(ctx, "second")) |
| 167 | } |
| 168 | |
| 169 | func TestWaitBuffer_WaitForNth_Blocks(t *testing.T) { |
| 170 | t.Parallel() |
nothing calls this directly
no test coverage detected