xmpp/filter_test.go
changeset 153 bbd4166df95d
parent 136 f35f853a52b6
equal deleted inserted replaced
152:69c5b4382e39 153:bbd4166df95d
    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 	}