Advertisement
Guest User

Untitled

a guest
Mar 26th, 2017
68
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.72 KB | None | 0 0
  1. def onLeave(self, details):
  2. """
  3. Implements :func:`autobahn.wamp.interfaces.ISession.onLeave`
  4. """
  5. if details.reason.startswith('wamp.error.'):
  6. self.log.error('{reason}: {wamp_message}', reason=details.reason, wamp_message=details.message)
  7.  
  8. if self._transport:
  9. self.disconnect()
  10.  
  11. exc = TransportLost()
  12. for requests in (self._call_reqs, self._publish_reqs, self._subscribe_reqs,
  13. self._unsubscribe_reqs, self._register_reqs, self._unregister_reqs):
  14. for request in requests.values():
  15. txaio.reject(request.on_reply, exc)
  16.  
  17. requests.clear()
  18. # do we ever call onLeave with a valid transport?
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement