Function as_async_generator

scrapy/utils/asyncgen.py:13–22

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

(
    it: Iterable[_T] | AsyncIterator[_T],
)

async def as_async_generator(
    it: Iterable[_T] | AsyncIterator[_T],
) -> AsyncGenerator[_T]:
    """Wraps an iterable (sync or async) into an async generator."""
    if isinstance(it, AsyncIterator):
        async for r in it:
            yield r
    else:
        for r in it:
            yield r