Method ReleaseThreshold

asyncbuffer/buffer.go:179–181

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

()

// ReleaseThreshold releases the pause, allowing the buffer to immediately
// read data beyond the pause threshold.
func (ab *AsyncBuffer) ReleaseThreshold() {
	ab.paused.Release()
}

// Error returns the error that occurred during reading data in background.
func (ab *AsyncBuffer) Error() error {