Function New

asyncbuffer/buffer.go:86–98

New creates a new AsyncBuffer that reads from the given io.ReadCloser in background and closes it when finished. r - io.ReadCloser to read data from dataLen - expected length of the data in r, <= 0 means unknown length finishFn - optional functions to call when the buffer is finished reading

(r io.ReadCloser, dataLen int, finishFn ...context.CancelFunc)

//	dataLen - expected length of the data in r, <= 0 means unknown length
//	finishFn - optional functions to call when the buffer is finished reading
func New(r io.ReadCloser, dataLen int, finishFn ...context.CancelFunc) *AsyncBuffer {
	ab := &AsyncBuffer{
		r:         r,
		dataLen:   dataLen,
		paused:    NewLatch(),
		chunkCond: NewCond(),
		finishFn:  finishFn,
	}

	go ab.readChunks()

	return ab
}

// NewReadFull creates a new AsyncBuffer that reads from the given io.ReadCloser
// in foreground, blocking until all data is read. It returns an error if reading