We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e7fc624 commit 3772c91Copy full SHA for 3772c91
1 file changed
trio_asyncio/base.py
@@ -213,10 +213,8 @@ async def run_coroutine(self, coro):
213
coro = asyncio.ensure_future(coro, loop=self)
214
return await run_future(coro)
215
216
- def wrap_generator(self, gen):
217
- # if inspect.isasyncgen(f):
218
- # return self.wrap_generator(f)
219
- return run_generator(self, gen())
+ def wrap_generator(self, gen, *args):
+ return run_generator(self, gen(*args))
220
221
async def run_asyncio(self, proc, *args):
222
"""Run an asyncio function or method from Trio.
0 commit comments