uasyncio: On scheduling ready coro, unmark it as I/O-waiting.

Coros which are passed to .add_reader()/.add_writer() are marked as
I/O-bound using .pend_throw(False). Before scheduling it for normal
execution again, we need to unmark it with .pend_throw(None).
pull/234/merge
Paul Sokolovsky 2017-12-14 19:14:42 +02:00
rodzic 203cc489c6
commit f6555bae97
1 zmienionych plików z 1 dodań i 0 usunięć

Wyświetl plik

@ -85,6 +85,7 @@ class PollEventLoop(EventLoop):
if isinstance(cb, tuple):
cb[0](*cb[1])
else:
cb.pend_throw(None)
self.call_soon(cb)