class RedisHandler(BaseHandler):
@tornado.web.authenticated
@tornado.web.asynchronous
@tornado.gen.engine
def post(self):
self.client = tornadoredis.Client()
self.client.connect()
yield tornado.gen.Task(self.client.subscribe,'notification')
self.client.listen(self.on_message)
def on_message(self,msg):
if msg.kind == 'message':
self.finish(dict(complete=True,message=msg.body))
return
上面的代码提出:
RuntimeError:finish() 调用了两次
这可能是由于使用没有 @asynchronous 装饰器的异步操作引起的。