Method Get

internal/compressions/writer_pool.go:51–69

(parentWriter io.Writer, level int)

}

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

	select {
	case writer := <-this.c:
		writer.Reset(parentWriter)
		writer.ResetFinish()
		return writer, nil
	default:
		writer, err := this.newFunc(parentWriter, level)
		if err != nil {
			return nil, err
		}
		writer.SetPool(this)
		return writer, nil
	}
}

func (this *WriterPool) Put(writer Writer) {
	if writer.IncreaseHit() > maxWriterHits {