Source File
	encode_stream_pool.go

Belonging Package
	github.com/francoispqt/gojay

package gojay

import (
	"io"
	"sync"
)

// NewEncoder returns a new StreamEncoder.
// It takes an io.Writer implementation to output data.
// It initiates the done channel returned by Done().
func (s stream) NewEncoder(w io.Writer) *StreamEncoder {
	enc := BorrowEncoder(w)
	return &StreamEncoder{Encoder: enc, nConsumer: 1, done: make(chan struct{}, 1), mux: &sync.RWMutex{}}
}

// BorrowEncoder borrows a StreamEncoder from the pool.
// It takes an io.Writer implementation to output data.
// It initiates the done channel returned by Done().
//
// If no StreamEncoder is available in the pool, it returns a fresh one
func (s stream) BorrowEncoder(w io.Writer) *StreamEncoder {
	streamEnc := streamEncPool.Get().(*StreamEncoder)
	streamEnc.w = w
	streamEnc.Encoder.err = nil
	streamEnc.done = make(chan struct{}, 1)
	streamEnc.Encoder.buf = streamEnc.buf[:0]
	streamEnc.nConsumer = 1
	streamEnc.isPooled = 0
	return streamEnc
}

func (s stream) borrowEncoder(w io.Writer) *StreamEncoder {
	streamEnc := streamEncPool.Get().(*StreamEncoder)
	streamEnc.isPooled = 0
	streamEnc.w = w
	streamEnc.Encoder.err = nil
	return streamEnc
}

The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds.