diff options
| author | mathieui <mathieui@mathieui.net> | 2021-01-25 10:13:49 +0100 |
|---|---|---|
| committer | mathieui <mathieui@mathieui.net> | 2021-01-29 15:33:44 +0100 |
| commit | 3642e2c7f436f6c0935ebcfa3ee279d4ac22adaf (patch) | |
| tree | d6af8be7c4ea1f9fe25b451cd79d64a45dc5dd0a | |
| parent | f15311bda8e5d1c227174771a30cde7013b0658f (diff) | |
| download | slixmpp-3642e2c7f436f6c0935ebcfa3ee279d4ac22adaf.tar.gz slixmpp-3642e2c7f436f6c0935ebcfa3ee279d4ac22adaf.tar.bz2 slixmpp-3642e2c7f436f6c0935ebcfa3ee279d4ac22adaf.tar.xz slixmpp-3642e2c7f436f6c0935ebcfa3ee279d4ac22adaf.zip | |
xmlstream: ensure slow futures are scheduled on this loop
| -rw-r--r-- | slixmpp/xmlstream/xmlstream.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/slixmpp/xmlstream/xmlstream.py b/slixmpp/xmlstream/xmlstream.py index 2cc5fe17..37cadc1f 100644 --- a/slixmpp/xmlstream/xmlstream.py +++ b/slixmpp/xmlstream/xmlstream.py @@ -1053,7 +1053,8 @@ class XMLStream(asyncio.BaseProtocol): self._continue_slow_send( task, already_run_filters - ) + ), + loop=self.loop, ) raise Exception("Slow coro, rescheduling") data = task.result() |