(self, response)
| 1061 | return self.highest_request_id |
| 1062 | |
| 1063 | def handle_pushed(self, response): |
| 1064 | log.debug("Message pushed from server: %r", response) |
| 1065 | for cb in self._push_watchers.get(response.event_type, []): |
| 1066 | try: |
| 1067 | cb(response.event_args) |
| 1068 | except Exception: |
| 1069 | log.exception("Pushed event handler errored, ignoring:") |
| 1070 | |
| 1071 | def send_msg(self, msg, request_id, cb, encoder=ProtocolHandler.encode_message, decoder=ProtocolHandler.decode_message, result_metadata=None): |
| 1072 | if self.is_defunct: |