(maxLines int)
| 15 | } |
| 16 | |
| 17 | func MakeMultiReaderLineBuffer(maxLines int) *MultiReaderLineBuffer { |
| 18 | if maxLines <= 0 { |
| 19 | maxLines = 1000 |
| 20 | } |
| 21 | |
| 22 | return &MultiReaderLineBuffer{ |
| 23 | lines: make([]string, 0, maxLines), |
| 24 | maxLines: maxLines, |
| 25 | totalLineCount: 0, |
| 26 | } |
| 27 | } |
| 28 | |
| 29 | // callback is synchronous. will block the consuming of lines and |
| 30 | // guaranteed to run in order. it is also guaranteed only one callback |
no outgoing calls
no test coverage detected