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 2feea6b..87df86a 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: |