tornado chat Learning

gistfile1.py

#将callback添加到一个类里面

class MessageMixin(object):
    waiters = set()

MessageMixin.waiters.add(callback)

#在有新的消息的时候遍历waiters返回
for callback in waiters:
    callbask(message)



def callback(self, messages):
    #callback也就是关闭连接然后返回传过来的消息
    # Closed client connection
    if self.request.connection.stream.closed():
            return
    self.finish(dict(messages=messages))