Coverage for /pythoncovmergedfiles/medio/medio/usr/local/lib/python3.8/site-packages/scrapy/utils/asyncgen.py: 25%

1from typing import AsyncGenerator, AsyncIterable, Iterable, Union 

2 

3 

4async def collect_asyncgen(result: AsyncIterable) -> list: 

5 results = [] 

6 async for x in result: 

7 results.append(x) 

8 return results 

9 

10 

11async def as_async_generator(it: Union[Iterable, AsyncIterable]) -> AsyncGenerator: 

12 """Wraps an iterable (sync or async) into an async generator.""" 

13 if isinstance(it, AsyncIterable): 

14 async for r in it: 

15 yield r 

16 else: 

17 for r in it: 

18 yield r