| 74 | |
| 75 | |
| 76 | class DummyStreamGenerator: |
| 77 | def __init__(self, *args, **kwargs): |
| 78 | self.generator_func = dummy_stream_generator |
| 79 | self.args = args |
| 80 | self.kwargs = kwargs |
| 81 | |
| 82 | async def __aiter__(self): |
| 83 | generator = self.generator_func(*self.args, **self.kwargs) |
| 84 | async for item in generator: |
| 85 | yield item |