Function NewReaderPool

internal/compressions/reader_pool.go:16–25

(maxSize int, newFunc func(reader io.Reader) (Reader, error))

}

func NewReaderPool(maxSize int, newFunc func(reader io.Reader) (Reader, error)) *ReaderPool {
	if maxSize <= 0 {
		maxSize = 1024
	}

	return &ReaderPool{
		c:       make(chan Reader, maxSize),
		newFunc: newFunc,
	}
}

func (this *ReaderPool) Get(parentReader io.Reader) (Reader, error) {
	select {