(t *testing.T)
| 479 | } |
| 480 | |
| 481 | func TestChunkQueue_Size(t *testing.T) { |
| 482 | queue, teardown := setupChunkQueue(t) |
| 483 | defer teardown() |
| 484 | |
| 485 | assert.EqualValues(t, 5, queue.Size()) |
| 486 | |
| 487 | err := queue.Close() |
| 488 | require.NoError(t, err) |
| 489 | assert.EqualValues(t, 0, queue.Size()) |
| 490 | } |
| 491 | |
| 492 | func TestChunkQueue_WaitFor(t *testing.T) { |
| 493 | queue, teardown := setupChunkQueue(t) |
nothing calls this directly
no test coverage detected