diff options
| author | Lance Stout <lancestout@gmail.com> | 2012-04-06 17:39:51 -0400 |
|---|---|---|
| committer | Lance Stout <lancestout@gmail.com> | 2012-04-06 17:39:51 -0400 |
| commit | aedbecd6735f6075f871412817f97639bf1365ec (patch) | |
| tree | 51624afc3df44c4015d02fe86e6328cd1634a529 /sleekxmpp/xmlstream/xmlstream.py | |
| parent | 83c5a4cd2fd70c250dfb7e566dad7084d99025a6 (diff) | |
| download | slixmpp-aedbecd6735f6075f871412817f97639bf1365ec.tar.gz slixmpp-aedbecd6735f6075f871412817f97639bf1365ec.tar.bz2 slixmpp-aedbecd6735f6075f871412817f97639bf1365ec.tar.xz slixmpp-aedbecd6735f6075f871412817f97639bf1365ec.zip | |
Correct the statemachine's ensure_any method.
It had not been updated to use the new condition instead of the old
threading event.
Diffstat (limited to 'sleekxmpp/xmlstream/xmlstream.py')
| -rw-r--r-- | sleekxmpp/xmlstream/xmlstream.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/sleekxmpp/xmlstream/xmlstream.py b/sleekxmpp/xmlstream/xmlstream.py index b14ed5eb..145383c1 100644 --- a/sleekxmpp/xmlstream/xmlstream.py +++ b/sleekxmpp/xmlstream/xmlstream.py @@ -1234,9 +1234,8 @@ class XMLStream(object): # be resent and processing will resume. while not self.stop.is_set(): # Only process the stream while connected to the server - if not self.state.ensure('connected', wait=0.1, - block_on_transition=True): - continue + if not self.state.ensure('connected', wait=0.1): + break # Ensure the stream header is sent for any # new connections. if not self.session_started_event.is_set(): |