diff options
| author | Lance Stout <lancestout@gmail.com> | 2012-03-11 21:15:01 -0700 |
|---|---|---|
| committer | Lance Stout <lancestout@gmail.com> | 2012-03-12 19:32:19 -0700 |
| commit | 1f5a3a444521e67afc7036cfd8f8e98fee982141 (patch) | |
| tree | 9ae162795ed3e85fb22f48aabab7a6cc8d0d2d91 /sleekxmpp/plugins/xep_0047/stream.py | |
| parent | be363e0b46681125a54e2d96f70c0c259216fee1 (diff) | |
| download | slixmpp-1f5a3a444521e67afc7036cfd8f8e98fee982141.tar.gz slixmpp-1f5a3a444521e67afc7036cfd8f8e98fee982141.tar.bz2 slixmpp-1f5a3a444521e67afc7036cfd8f8e98fee982141.tar.xz slixmpp-1f5a3a444521e67afc7036cfd8f8e98fee982141.zip | |
Move XEP-0047 to new system.
Diffstat (limited to 'sleekxmpp/plugins/xep_0047/stream.py')
| -rw-r--r-- | sleekxmpp/plugins/xep_0047/stream.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/sleekxmpp/plugins/xep_0047/stream.py b/sleekxmpp/plugins/xep_0047/stream.py index 73c34425..49f56f36 100644 --- a/sleekxmpp/plugins/xep_0047/stream.py +++ b/sleekxmpp/plugins/xep_0047/stream.py @@ -28,7 +28,7 @@ class IBBytestream(object): self._send_seq_lock = threading.Lock() self._recv_seq_lock = threading.Lock() - + self.stream_started = threading.Event() self.stream_in_closed = threading.Event() self.stream_out_closed = threading.Event() @@ -55,7 +55,7 @@ class IBBytestream(object): iq['from'] = self.sender iq['ibb_data']['sid'] = self.sid iq['ibb_data']['seq'] = seq - iq['ibb_data']['data'] = data + iq['ibb_data']['data'] = data self.window_empty.clear() self.window_ids.add(iq['id']) iq.send(block=False, callback=self._recv_ack) @@ -113,7 +113,7 @@ class IBBytestream(object): iq['from'] = self.sender iq['ibb_close']['sid'] = self.sid self.stream_out_closed.set() - iq.send(block=False, + iq.send(block=False, callback=lambda x: self.stream_in_closed.set()) self.xmpp.event('ibb_stream_end', self) |