diff options
author | Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> | 2018-07-01 18:46:33 +0200 |
---|---|---|
committer | Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> | 2018-07-01 18:46:33 +0200 |
commit | 3502480384bd7d9f4e4eb1a3b92e8df08f4e487c (patch) | |
tree | a2e68835f4de6c32808412455f88310c05528191 /slixmpp/plugins/xep_0047/stream.py | |
parent | 66909aafb300868ffd3ed9ab02bc3bd28c49a6e9 (diff) | |
download | slixmpp-3502480384bd7d9f4e4eb1a3b92e8df08f4e487c.tar.gz slixmpp-3502480384bd7d9f4e4eb1a3b92e8df08f4e487c.tar.bz2 slixmpp-3502480384bd7d9f4e4eb1a3b92e8df08f4e487c.tar.xz slixmpp-3502480384bd7d9f4e4eb1a3b92e8df08f4e487c.zip |
Switch from @asyncio.coroutine to async def everywhere.
Diffstat (limited to 'slixmpp/plugins/xep_0047/stream.py')
-rw-r--r-- | slixmpp/plugins/xep_0047/stream.py | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/slixmpp/plugins/xep_0047/stream.py b/slixmpp/plugins/xep_0047/stream.py index 3be894eb..b3767265 100644 --- a/slixmpp/plugins/xep_0047/stream.py +++ b/slixmpp/plugins/xep_0047/stream.py @@ -31,8 +31,7 @@ class IBBytestream(object): self.recv_queue = asyncio.Queue() - @asyncio.coroutine - def send(self, data, timeout=None): + async def send(self, data, timeout=None): if not self.stream_started or self.stream_out_closed: raise socket.error if len(data) > self.block_size: @@ -56,22 +55,20 @@ class IBBytestream(object): iq['ibb_data']['sid'] = self.sid iq['ibb_data']['seq'] = seq iq['ibb_data']['data'] = data - yield from iq.send(timeout=timeout) + await iq.send(timeout=timeout) return len(data) - @asyncio.coroutine - def sendall(self, data, timeout=None): + async def sendall(self, data, timeout=None): sent_len = 0 while sent_len < len(data): - sent_len += yield from self.send(data[sent_len:self.block_size], timeout=timeout) + sent_len += await self.send(data[sent_len:self.block_size], timeout=timeout) - @asyncio.coroutine - def sendfile(self, file, timeout=None): + async def sendfile(self, file, timeout=None): while True: data = file.read(self.block_size) if not data: break - yield from self.send(data, timeout=timeout) + await self.send(data, timeout=timeout) def _recv_data(self, stanza): new_seq = stanza['ibb_data']['seq'] |