(async_gen)
| 20 | |
| 21 | |
| 22 | async def concat_async(async_gen): |
| 23 | rv = [] |
| 24 | async def collect(): |
| 25 | async for event in async_gen: |
| 26 | rv.append(event) |
| 27 | await collect() |
| 28 | return concat(rv) |
| 29 | |
| 30 | |
| 31 | async def generate_async(self, *args, **kwargs): |
no test coverage detected
searching dependent graphs…