Method create_benchmark_agent

tests/bench/base.py:65–66

(self)

            self.app.main()

    def create_benchmark_agent(self):
        self._agent = self.app.agent(self.consume_topic)(self.process)

    async def process(self, stream):
        time_last = None