Method flush

asyncbuffer/buffer_test.go:103–106

flush unlocks the reader, allowing it to return all data as usual

()

// flush unlocks the reader, allowing it to return all data as usual
func (r *blockingReader) flush() {
	r.unlocking.Store(true) // allow reading data without blocking
	r.mu.Unlock()           // and continue
}

// generateSourceData generates a byte slice with 4.5 chunks of data
func generateSourceData(t *testing.T, size int) ([]byte, *countingReader) {