xmlstream: ensure slow futures are scheduled on this loop
This commit is contained in:
parent
f15311bda8
commit
3642e2c7f4
@ -1053,7 +1053,8 @@ class XMLStream(asyncio.BaseProtocol):
|
|||||||
self._continue_slow_send(
|
self._continue_slow_send(
|
||||||
task,
|
task,
|
||||||
already_run_filters
|
already_run_filters
|
||||||
)
|
),
|
||||||
|
loop=self.loop,
|
||||||
)
|
)
|
||||||
raise Exception("Slow coro, rescheduling")
|
raise Exception("Slow coro, rescheduling")
|
||||||
data = task.result()
|
data = task.result()
|
||||||
|
Loading…
Reference in New Issue
Block a user