(self, process_func, *args, **kwargs)
| 432 | |
| 433 | class AsyncGenerator: |
| 434 | def __init__(self, process_func, *args, **kwargs): |
| 435 | self.queue = asyncio.Queue() |
| 436 | self.shutdown_event = threading.Event() |
| 437 | self.iterator_task = None |
| 438 | self.process_func = process_func |
| 439 | self.args = args |
| 440 | self.kwargs = kwargs |
| 441 | |
| 442 | async def producer(self): |
| 443 | # Data generation logic here |
nothing calls this directly
no outgoing calls
no test coverage detected