xmpp/roster.go
changeset 162 7b5586a5e109
parent 158 2d948fcbb5d7
child 181 750bc33ccdda
equal deleted inserted replaced
161:6570a6a9683b 162:7b5586a5e109
    77 func (r *Roster) makeFilters() (Filter, Filter) {
    77 func (r *Roster) makeFilters() (Filter, Filter) {
    78 	rosterUpdate := make(chan Stanza)
    78 	rosterUpdate := make(chan Stanza)
    79 	go r.rosterMgr(rosterUpdate)
    79 	go r.rosterMgr(rosterUpdate)
    80 	recv := func(in <-chan Stanza, out chan<- Stanza) {
    80 	recv := func(in <-chan Stanza, out chan<- Stanza) {
    81 		defer close(out)
    81 		defer close(out)
       
    82 		defer close(rosterUpdate)
    82 		for stan := range in {
    83 		for stan := range in {
    83 			rosterUpdate <- stan
    84 			rosterUpdate <- stan
    84 			out <- stan
    85 			out <- stan
    85 		}
    86 		}
    86 	}
    87 	}