sse_protocol.py 文件源码

def connectionLost(self, reason=connectionDone):
        self.log.failure('SSE connection lost', reason, LogLevel.warn)
        self.setTimeout(None)  # Cancel the timeout
        for d in list(self._waiting):
            d.callback(None)
        self._waiting = []