Method Get

internal/utils/bfs/gzip_writer_pool.go:39–47

(rawWriter io.Writer)

}

func (this *GzipWriterPool) Get(rawWriter io.Writer) (*gzip.Writer, error) {
	select {
	case w := <-this.getC():
		w.Reset(rawWriter)
		return w, nil
	default:
		return gzip.NewWriterLevel(rawWriter, gzip.BestSpeed)
	}
}

func (this *GzipWriterPool) Put(writer *gzip.Writer) {
	select {