Method Close

internal/stream/pipe.go:134–139

Close implements io.Closer. it cancels prefetching and releases resources.

()

// Close implements io.Closer.
// it cancels prefetching and releases resources.
func (p *StreamPipe) Close() error {
	p.closeOnce.Do(func() {
		p.cancel()
	})
	return nil
}

// prefetch runs in a goroutine, fetching blocks concurrently and sending to blockQueue.
func (p *StreamPipe) prefetch() {