Searched defs:streamMerger (Results 1 – 1 of 1) sorted by relevance
66 type streamMerger struct { struct67 OutW, ErrW *io.PipeWriter68 mutex sync.Mutex69 inner io.Writer70 wg sync.WaitGroup71 outR, errR *bufio.Reader86 func (m *streamMerger) Start() {106 func (m *streamMerger) Wait() {