Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def onLeave(self, details):
- """
- Implements :func:`autobahn.wamp.interfaces.ISession.onLeave`
- """
- if details.reason.startswith('wamp.error.'):
- self.log.error('{reason}: {wamp_message}', reason=details.reason, wamp_message=details.message)
- if self._transport:
- self.disconnect()
- exc = TransportLost()
- for requests in (self._call_reqs, self._publish_reqs, self._subscribe_reqs,
- self._unsubscribe_reqs, self._register_reqs, self._unregister_reqs):
- for request in requests.values():
- txaio.reject(request.on_reply, exc)
- requests.clear()
- # do we ever call onLeave with a valid transport?
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement