Method Read

asyncbuffer/buffer_test.go:54–60

Read reads data from the testReader, simulating a slow read and a potential failure

(p []byte)

// Read reads data from the testReader, simulating a slow read and a potential failure
func (r *erraticReader) Read(p []byte) (n int, err error) {
	cur := r.reader.BytesRead()
	if r.failAt > 0 && r.failAt < cur+int64(len(p)) {
		return 0, errors.New("simulated read failure")
	}
	return r.reader.Read(p)
}

// Close forwards closing to the underlying reader
func (r *erraticReader) Close() error {