From aedbecd6735f6075f871412817f97639bf1365ec Mon Sep 17 00:00:00 2001 From: Lance Stout Date: Fri, 6 Apr 2012 17:39:51 -0400 Subject: Correct the statemachine's ensure_any method. It had not been updated to use the new condition instead of the old threading event. --- sleekxmpp/xmlstream/xmlstream.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'sleekxmpp/xmlstream') 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(): -- cgit v1.2.3