Method Wait

asyncbuffer/buffer.go:154–175

Wait waits for the reader to finish reading all data and returns the total length of the data read.

()

// Wait waits for the reader to finish reading all data and returns
// the total length of the data read.
func (ab *AsyncBuffer) Wait() (int, error) {
	// Wait ends till the end of the stream: unpause the reader
	ab.paused.Release()

	// Get initial cursor before first check
	cursor := ab.chunkCond.Cursor()

	for {
		// We can not read data from the closed reader
		if err := ab.closedError(); err != nil {
			return 0, err
		}

		// In case the reader is finished reading, we can return immediately
		if ab.finished.Load() {
			return int(ab.bytesRead.Load()), ab.Error()
		}

		// Lock until the next chunk is ready
		cursor = ab.chunkCond.Wait(cursor)
	}
}

// ReleaseThreshold releases the pause, allowing the buffer to immediately
// read data beyond the pause threshold.