流包装器.

        通过调用异步生成器传输流数据.

        Parameters:
            cor (AsyncIterator): - 异步迭代器
            ID (str): - 任务的ID

        Return:
            (bool): - 当正常调用则返回True

async def _asyncgen_wrap(self, cor: AsyncIterator, ID: str):
        """流包装器.

        通过调用异步生成器传输流数据.

        Parameters:
            cor (AsyncIterator): - 异步迭代器
            ID (str): - 任务的ID

        Return:
            (bool): - 当正常调用则返回True

        """
        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