Function newResettableReader

utils/network/resettable_reader.go:53–61

(reader io.Reader, bufferLimit int64, onFinishCallback func([]byte))

}

func newResettableReader(reader io.Reader, bufferLimit int64, onFinishCallback func([]byte)) *resettableReader {
	return &resettableReader{
		reader:           reader,
		buffer:           new(bytes.Buffer),
		bufferLimit:      bufferLimit,
		bytesRead:        0,
		onFinishCallback: onFinishCallback,
	}
}