Struct AsyncBuffer

asyncbuffer/buffer.go:60–78

AsyncBuffer is a wrapper around io.Reader that reads data in chunks in background and allows reading from synchronously.

// AsyncBuffer is a wrapper around io.Reader that reads data in chunks
// in background and allows reading from synchronously.
type AsyncBuffer struct {
	r       io.ReadCloser // Upstream reader
	dataLen int           // Expected length of the data in r, <= 0 means unknown length

	chunks []*byteChunk // References to the chunks read from the upstream reader
	mu     sync.RWMutex // Mutex on chunks slice

	err       atomic.Value // Error that occurred during reading
	bytesRead atomic.Int64 // Total length of the data read

	finished atomic.Bool // Indicates that the buffer has finished reading
	closed   atomic.Bool // Indicates that the buffer was closed

	paused    *Latch // Paused buffer does not read data beyond threshold
	chunkCond *Cond  // Ticker that signals when a new chunk is ready

	finishOnce sync.Once
	finishFn   []context.CancelFunc
}

// New creates a new AsyncBuffer that reads from the given io.ReadCloser in background
// and closes it when finished.