diff options
| -rw-r--r-- | xmpp/stream_pair.go | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/xmpp/stream_pair.go b/xmpp/stream_pair.go index 87df86a..2feea6b 100644 --- a/xmpp/stream_pair.go +++ b/xmpp/stream_pair.go @@ -13,13 +13,13 @@ func runStreamPair(s *session) { for { select { - case data := <-s.in: - switch data.(type) { - case SessionShouldDisconnect: - return - default: - log.Printf("Unknown data '%d'!\n", data) - } +// case data := <-s.in: +// switch data.(type) { +// case SessionShouldDisconnect: +// return +// default: +// log.Printf("Unknown data '%d'!\n", data) +// } case t := <-s.rx: err := buf.add(t) if err != nil { @@ -66,13 +66,13 @@ func openStream(s *session) xml.EndElement { func syncStreams(s *session) { for { select { - case data := <-s.in: - switch data.(type) { - case SessionShouldDisconnect: - return - default: - log.Printf("Unhandled data '%d' during stream sync!\n", data) - } +// case data := <-s.in: +// switch data.(type) { +// case SessionShouldDisconnect: +// return +// default: +// log.Printf("Unhandled data '%d' during stream sync!\n", data) +// } case t := <-s.rx: switch token := t.(type) { case xml.StartElement: |