diff -r 9d7e8333948b -r ebb86cbdd218 stream.go --- a/stream.go Sat Aug 31 23:08:21 2013 +0100 +++ b/stream.go Mon Sep 02 20:38:02 2013 -0700 @@ -300,39 +300,6 @@ } } -// Stanzas from the remote go up through a stack of filters to the -// app. This function manages the filters. -func filterTop(filterOut <-chan <-chan Stanza, filterIn chan<- <-chan Stanza, - topFilter <-chan Stanza, app chan<- Stanza) { - defer close(app) -Loop: - for { - select { - case newFilterOut := <-filterOut: - if newFilterOut == nil { - Warn.Log("Received nil filter") - filterIn <- nil - continue - } - filterIn <- topFilter - topFilter = newFilterOut - - case data, ok := <-topFilter: - if !ok { - break Loop - } - app <- data - } - } -} - -func filterBottom(from <-chan Stanza, to chan<- Stanza) { - defer close(to) - for data := range from { - to <- data - } -} - func handleStream(ss *stream) { }