equal
deleted
inserted
replaced
198 |
198 |
199 func (cl *Client) startFilter(srvIn <-chan Stanza) <-chan Stanza { |
199 func (cl *Client) startFilter(srvIn <-chan Stanza) <-chan Stanza { |
200 cliOut := make(chan Stanza) |
200 cliOut := make(chan Stanza) |
201 filterOut := make(chan (<-chan Stanza)) |
201 filterOut := make(chan (<-chan Stanza)) |
202 filterIn := make(chan (<-chan Stanza)) |
202 filterIn := make(chan (<-chan Stanza)) |
203 go filter(srvIn, cliOut, filterOut, filterIn) |
203 nullFilter := make(chan Stanza) |
|
204 go filterBottom(srvIn, nullFilter) |
|
205 go filterTop(filterOut, filterIn, nullFilter, cliOut) |
204 cl.filterOut = filterOut |
206 cl.filterOut = filterOut |
205 cl.filterIn = filterIn |
207 cl.filterIn = filterIn |
206 return cliOut |
208 return cliOut |
207 } |
209 } |
208 |
210 |