Commit b1930151 authored by Yury Selivanov's avatar Yury Selivanov

asyncio: Sync with upstream

parent 04928039
...@@ -348,6 +348,9 @@ class BaseEventLoop(events.AbstractEventLoop): ...@@ -348,6 +348,9 @@ class BaseEventLoop(events.AbstractEventLoop):
self._asyncgens.discard(agen) self._asyncgens.discard(agen)
if not self.is_closed(): if not self.is_closed():
self.create_task(agen.aclose()) self.create_task(agen.aclose())
# Wake up the loop if the finalizer was called from
# a different thread.
self._write_to_self()
def _asyncgen_firstiter_hook(self, agen): def _asyncgen_firstiter_hook(self, agen):
if self._asyncgens_shutdown_called: if self._asyncgens_shutdown_called:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment