Lines Matching refs:merger
17 merger := NewOutputMerger(tee)
24 merger.Add("pipe1", rp1)
31 merger.Add("pipe2", rp2)
35 case <-merger.Output:
36 t.Fatalf("merger produced incomplete line")
42 case <-merger.Output:
43 t.Fatalf("merger produced incomplete line")
48 got := string(<-merger.Output)
54 got = string(<-merger.Output)
60 got = string(<-merger.Output)
65 if err := <-merger.Err; err == nil {
66 t.Fatalf("merger did not produce an error on pipe close")
68 t.Fatalf("merger produced wrong error: %v", err)
72 got = string(<-merger.Output)
77 merger.Wait()
