equal
deleted
inserted
replaced
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 } |