wamp.py 文件源码

def _handle_interrupt_status(self):
        self._kernel_event_dispatcher.on_interrupt_fail(self._interrupt_timeout, "NA")
        for key in [k for k in status_msg_cache.keys() if k != "idle"]:
            try:
                status_msg_cache[key].callback(True)
            except AlreadyCalledError:
                status_msg_cache.__delitem__(key)