async def _wrap_gen(self, ID: str):
        """异步迭代器包装.

        Parameters:
            ID (str): - 任务ID

        Yield:
            (Any): - 从异步迭代器结果队列中获取的结果

        Raise:
            (StopAsyncIteration): - 异步迭代器终止时抛出该异常

        """
        while True:
            result = await self._gens_queue[ID].get()
            if isinstance(result, StopAsyncIteration):
                del self._gens_queue[ID]
                break
            else:
                yield result