(t *testing.T)
| 84 | } |
| 85 | |
| 86 | func TestBufferedConcurrency(t *testing.T) { |
| 87 | t.Parallel() |
| 88 | bufLog := NewBufferedLogger(io.Discard, 32, |
| 89 | WithFlushPeriod(flushPeriod), |
| 90 | WithPrellocatedBuffer(bufferSize), |
| 91 | ) |
| 92 | testConcurrency(t, log.NewLogfmtLogger(bufLog), 10000) |
| 93 | } |
| 94 | |
| 95 | func TestOnFlushCallback(t *testing.T) { |
| 96 | var ( |
nothing calls this directly
no test coverage detected