Method Write

writer_test.go:50–54

(p []byte)

}

func (b *bufferWithMu) Write(p []byte) (int, error) {
	b.mu.Lock()
	defer b.mu.Unlock()
	return b.buf.Write(p)
}

func (b *bufferWithMu) Read(p []byte) (int, error) {
	b.mu.RLock()