equal
deleted
inserted
replaced
215 break |
215 break |
216 } |
216 } |
217 } |
217 } |
218 } |
218 } |
219 |
219 |
220 // BUG(cjyar) Allow extensions to provide filters in the form of "in |
|
221 // chan<- Stanza, out <-chan Stanza". |
|
222 func (cl *Client) readStream(srvIn <-chan interface{}, cliOut chan<- Stanza) { |
220 func (cl *Client) readStream(srvIn <-chan interface{}, cliOut chan<- Stanza) { |
223 defer tryClose(srvIn, cliOut) |
221 defer tryClose(srvIn, cliOut) |
224 |
222 |
225 handlers := make(map[string] func(Stanza) bool) |
223 handlers := make(map[string] func(Stanza) bool) |
226 for { |
224 for { |