--- 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) {
}