Lines Matching refs:merger

17 	merger := NewOutputMerger(tee)
24 	merger.Add("pipe1", rp1)
31 	merger.Add("pipe2", rp2)
35 	case <-merger.Output:
42 	case <-merger.Output:
48 	got := string(<-merger.Output)
54 	got = string(<-merger.Output)
60 	got = string(<-merger.Output)
65 	if err := <-merger.Err; err == nil {
72 	got = string(<-merger.Output)
77 	merger.Wait()