equal
deleted
inserted
replaced
168 break |
168 break |
169 } |
169 } |
170 } |
170 } |
171 } |
171 } |
172 |
172 |
|
173 // BUG(cjyar) Allow extensions to specify extended structs with |
|
174 // corresponding namespaces via "func(xml.Name) Stanza". |
|
175 // BUG(cjyar) Allow extensions to provide filters in the form of "in |
|
176 // chan<- Stanza, out <-chan Stanza". |
173 func (cl *Client) readStream(srvIn <-chan interface{}, cliOut chan<- Stanza) { |
177 func (cl *Client) readStream(srvIn <-chan interface{}, cliOut chan<- Stanza) { |
174 defer tryClose(srvIn, cliOut) |
178 defer tryClose(srvIn, cliOut) |
175 |
179 |
176 handlers := make(map[string] func(Stanza) bool) |
180 handlers := make(map[string] func(Stanza) bool) |
177 for { |
181 for { |