from tornado.web import RequestHandler class TestHandler(RequestHandler): def initialize(self, solvable_connector): self.solvable_connector = solvable_connector async def get(self): self.solvable_connector.send('test', {}) resp_key, resp_data = await self.solvable_connector.recv() self.write(resp_data)