(t *testing.T)
| 401 | } |
| 402 | |
| 403 | func TestSendProcess_AfterCancel(t *testing.T) { |
| 404 | ctx, cancel := context.WithCancel(context.Background()) |
| 405 | pool := newTestBasePool(ctx, cancel) |
| 406 | cancel() |
| 407 | |
| 408 | mustFinish(t, 2*time.Second, "sendProcess blocked after cancel", func() { |
| 409 | pool.sendProcess(newTestBaseline()) |
| 410 | }) |
| 411 | } |
| 412 | |
| 413 | func TestSendProcess_FullBufferUnblocksOnCancel(t *testing.T) { |
| 414 | ctx, cancel := context.WithCancel(context.Background()) |
nothing calls this directly
no test coverage detected