mrtoth/baseimage-tutorial-framework
1
0
Fork 0
mirror of https://github.com/avatao-content/baseimage-tutorial-framework synced 2024-11-22 21:01:31 +00:00
Code Issues Releases Wiki Activity

Remove ambiguous key parameter from EventHanderConnector

Browse Source
This commit is contained in:
Kristóf Tóth 2018-04-13 20:33:35 +02:00
parent 3c12b5503e
commit fe7bd4a678
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/tfw/networking/server/event_handler_connector.py
View File

@ -34,5 +34,5 @@ class EventHandlerConnector(EventHandlerDownlinkConnector, EventHandlerUplinkCon
def register_callback(self, callback): def register_callback(self, callback):
self._zmq_pull_stream.on_recv(callback) self._zmq_pull_stream.on_recv(callback)
def send_message(self, message: dict, key: str = None): def send_message(self, message: dict):
self._zmq_pub_socket.send_multipart(serialize_tfw_msg(message)) self._zmq_pub_socket.send_multipart(serialize_tfw_msg(message))

4
lib/tfw/networking/server/zmq_websocket_handler.py
View File

@ -46,7 +46,7 @@ class ZMQWebSocketHandler(WebSocketHandler, ABC):
def mirror(self, message): def mirror(self, message):
message = message['data'] message = message['data']
self._event_handler_connector.send_message(message, message['key']) self._event_handler_connector.send_message(message)
def on_message(self, message): def on_message(self, message):
LOG.debug('Received on WebSocket: %s', message) LOG.debug('Received on WebSocket: %s', message)
@ -57,7 +57,7 @@ class ZMQWebSocketHandler(WebSocketHandler, ABC):
raise NotImplementedError raise NotImplementedError
def send_message(self, message: dict, key: str = None): def send_message(self, message: dict, key: str = None):
self._event_handler_connector.send_message(message, key) self._event_handler_connector.send_message(message)
@abstractmethod @abstractmethod
def handle_trigger(self, message): def handle_trigger(self, message):