비동기 이터레이터

Python code

import asyncio

class AsyncCounter:
    """비동기 카운터 이터레이터"""
    def __init__(self, start: int, stop: int):
        self.current = start
        self.stop = stop

    def __aiter__(self):
        return self

    async def __anext__(self):
        if self.current >= self.stop:
            raise StopAsyncIteration
        value = self.current
        self.current += 1
        await asyncio.sleep(0.1)  # 비동기 작업
        return value

class AsyncChain:
    """여러 비동기 이터러블을 연결"""
    def __init__(self, *iterables):
        self._iterables = iterables

    def __aiter__(self):
        return self._iterate()

    async def _iterate(self):
        for iterable in self._iterables:
            async for item in iterable:
                yield item

async def main():
    # 기본 사용
    async for num in AsyncCounter(0, 5):
        print(f"  카운트: {num}")

    # 비동기 이터러블 체이닝
    chained = AsyncChain(
        AsyncCounter(0, 3),
        AsyncCounter(10, 13),
    )
    result = [x async for x in chained]
    print(f"체이닝 결과: {result}")

asyncio.run(main())