stream.go
changeset 121 ebb86cbdd218
parent 119 712aa5780660
--- 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) {
 }