(t *testing.T)
| 63 | } |
| 64 | |
| 65 | func testBatchQueuePutAfterCloseFails(t *testing.T) { |
| 66 | bq := newBatchQueue(10) |
| 67 | bq.Close() |
| 68 | if put := bq.Put(newWriteBatch(time.Now(), time.Hour*100)); put { |
| 69 | t.Fatal("put batch into closed queue") |
| 70 | } |
| 71 | } |
| 72 | |
| 73 | func testBatchQueueGetWorksAfterClose(t *testing.T) { |
| 74 | bq := newBatchQueue(10) |
nothing calls this directly
no test coverage detected