Lines Matching refs:merger

237 	merger := vmimpl.NewOutputMerger(tee)
242 	merger.AddDecoder("console", conRpipe, decoder)
243 	if err := waitForConsoleConnect(merger); err != nil {
245 		merger.Wait()
251 		merger.Wait()
266 		merger.Wait()
272 	merger.Add("ssh", sshRpipe)
290 		case err := <-merger.Err:
293 			merger.Wait()
317 		merger.Wait()
321 	return merger.Output, errc, nil
324 func waitForConsoleConnect(merger *vmimpl.OutputMerger) error {
339 		case out := <-merger.Output: