Function MakeSyncBufferFromReader

pkg/util/syncbuf/syncbuf.go:25–29

spawns a goroutine to copy the reader to the buffer

(r io.Reader)

// spawns a goroutine to copy the reader to the buffer
func MakeSyncBufferFromReader(r io.Reader) *SyncBuffer {
	rtn := MakeSyncBuffer()
	go io.Copy(rtn, r)
	return rtn
}

func (s *SyncBuffer) Write(p []byte) (n int, err error) {
	s.lock.Lock()