code: async def _wrap_gen(self, ID: str):
          
          while True:
              result = await self._gens_queue[ID].get()
              if isinstance(result, StopAsyncIteration):
                  del self._gens_queue[ID]
                  break
              else:
                  yield result
docs: 异步迭代器包装.
  
          Parameters:
              ID (str): - 任务ID
  
          Yield:
              (Any): - 从异步迭代器结果队列中获取的结果
  
          Raise:
              (StopAsyncIteration): - 异步迭代器终止时抛出该异常