(self)
Return results one-by-one as they are ready
Return results one-by-one as they are ready
Return results one - by - one as they are ready
async def results_generator(self) -> AsyncIterator[_T]:
        """Return results one-by-one as they are ready"""
        for task_id in self.task_ids:
            yield (await self.pool.results([task_id]))[0]
async def results_generator ( self ) -> AsyncIterator [ _T ] : for task_id in self . task_ids : yield ( await self . pool . results ( [ task_id ] ) ) [ 0 ]