flushNextChunk unlocks the reader, allowing it to return the next chunk of data
()
| 96 | |
| 97 | // flushNextChunk unlocks the reader, allowing it to return the next chunk of data |
| 98 | func (r *blockingReader) flushNextChunk() { |
| 99 | r.mu.Unlock() |
| 100 | } |
| 101 | |
| 102 | // flush unlocks the reader, allowing it to return all data as usual |
| 103 | func (r *blockingReader) flush() { |
no outgoing calls
no test coverage detected