summaryrefslogtreecommitdiff
path: root/sleekxmpp/xmlstream/xmlstream.py
diff options
context:
space:
mode:
Diffstat (limited to 'sleekxmpp/xmlstream/xmlstream.py')
-rw-r--r--sleekxmpp/xmlstream/xmlstream.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/sleekxmpp/xmlstream/xmlstream.py b/sleekxmpp/xmlstream/xmlstream.py
index 44f83840..594583a8 100644
--- a/sleekxmpp/xmlstream/xmlstream.py
+++ b/sleekxmpp/xmlstream/xmlstream.py
@@ -154,7 +154,7 @@ class XMLStream(object):
def _process(self):
"Start processing the socket."
firstrun = True
- while firstrun or self.state['reconnect']:
+ while self.run and (firstrun or self.state['reconnect']):
self.state.set('processing', True)
firstrun = False
try:
@@ -229,7 +229,7 @@ class XMLStream(object):
edepth += 1
def _sendThread(self):
- while True:
+ while self.run:
data = self.sendqueue.get(True)
logging.debug("SEND: %s" % data)
try: