Function NewWriterPool

internal/compressions/writer_pool.go:40–49

(maxSize int, newFunc func(writer io.Writer, level int) (Writer, error))

}

func NewWriterPool(maxSize int, newFunc func(writer io.Writer, level int) (Writer, error)) *WriterPool {
	if maxSize <= 0 {
		maxSize = 1024
	}

	return &WriterPool{
		c:       make(chan Writer, maxSize),
		newFunc: newFunc,
	}
}

func (this *WriterPool) Get(parentWriter io.Writer, level int) (Writer, error) {
	if isBusy {