Add chan xml.Token xmpp.session.rx

This allows the goroutine which fetches all tokens from the server to
forward them to the main goroutine of the session.

1 files changed, 4 insertions, 0 deletions

diff --git a/xmpp/session.go b/xmpp/session.go
index 080fb21..2162d66 100644
--- a/xmpp/session.go
+++ b/xmpp/session.go
@@ -17,6 +17,7 @@ type session struct {
 	transport *tls.Conn
 	ed        encoderDecoder
 	streams   []stream
+	rx        chan xml.Token
 }
 
 func StartSession(out chan any, jid string, pwd string) chan any {
@@ -26,6 +27,7 @@ func StartSession(out chan any, jid string, pwd string) chan any {
 	s.in = make(chan any)
 	s.out = out
 	s.streams = make([]stream, 0)
+	s.rx = make(chan xml.Token, 0)
 
 	go s.run()
 
@@ -55,6 +57,8 @@ func (s *session) run() {
 			case SessionShouldDisconnect: return
 			default: log.Printf("Unknown data '%d'!\n", data)
 			}
+		case _ = <-s.rx:
+			// TODO route received XML token here
 		}
 	}
 }