Made it compatible with tornado 6

pull/58/head
Sheng 2019-03-12 21:52:17 +08:00
parent 3f1e53eaad
commit f9b640c745
1 changed files with 2 additions and 1 deletions

View File

@ -405,7 +405,8 @@ class WsockHandler(MixinHandler, tornado.websocket.WebSocketHandler):
worker = workers.get(worker_id)
if worker:
workers[worker_id] = None
self.set_nodelay(True)
if self.stream:
self.set_nodelay(True)
worker.set_handler(self)
self.worker_ref = weakref.ref(worker)
self.loop.add_handler(worker.fd, worker, IOLoop.READ)