equal
deleted
inserted
replaced
32 } |
32 } |
33 |
33 |
34 func filterN(numFilts int, t *testing.T) { |
34 func filterN(numFilts int, t *testing.T) { |
35 add := make(chan Filter) |
35 add := make(chan Filter) |
36 in := make(chan Stanza) |
36 in := make(chan Stanza) |
|
37 defer close(in) |
37 out := make(chan Stanza) |
38 out := make(chan Stanza) |
38 go filterMgr(add, in, out) |
39 go filterMgr(add, in, out) |
39 for i := 0; i < numFilts; i++ { |
40 for i := 0; i < numFilts; i++ { |
40 add <- passthru |
41 add <- passthru |
41 } |
42 } |