code: async def _asyncgen_wrap(self, cor: AsyncIterator, ID: str):
          
          response = {
              "MPRPC": self.VERSION,
              "CODE": 201,
              "MESSAGE": {
                  "ID": ID
              }
          }
          self.writer(response)
          if self.debug:
              access_logger.info(
                  "Task[{}]: response stream start".format(ID),
                  extra=self._extra
              )
          async for i in cor:
              response = {
                  "MPRPC": self.VERSION,
                  "CODE": 202,
                  "MESSAGE": {
                      "ID": ID,
                      'RESULT': i
                  }
              }
              self.writer(response)
              if self.debug:
                  access_logger.info(
                      "Task[{}]: response stream yield".format(ID),
                      extra=self._extra
                  )
          response = {
              "MPRPC": self.VERSION,
              "CODE": 206,
              "MESSAGE": {
                  "ID": ID
              }
          }
          self.writer(response)
          if self.debug:
              access_logger.info(
                  "Task[{}]: response stream end".format(ID),
                  extra=self._extra
              )
          return True
docs: 流包装器.
  
          通过调用异步生成器传输流数据.
  
          Parameters:
              cor (AsyncIterator): - 异步迭代器
              ID (str): - 任务的ID
  
          Return:
              (bool): - 当正常调用则返回True