diff --git a/lib/tfw/networking/event_handler_connector.py b/lib/tfw/networking/event_handler_connector.py index 60cbb94..74b6270 100644 --- a/lib/tfw/networking/event_handler_connector.py +++ b/lib/tfw/networking/event_handler_connector.py @@ -8,7 +8,7 @@ from .serialization import serialize_tfw_msg, with_deserialize_tfw_msg LOG = logging.getLogger(__name__) -class EventHandlerDownlinkConnector(): +class EventHandlerDownlinkConnector: def __init__(self, bind_addr): self._zmq_pull_socket = zmq.Context.instance().socket(zmq.PULL) self._zmq_pull_socket.setsockopt(zmq.RCVHWM, 0) @@ -24,7 +24,7 @@ class EventHandlerDownlinkConnector(): self._zmq_pull_stream.close() -class EventHandlerUplinkConnector(): +class EventHandlerUplinkConnector: def __init__(self, bind_addr): self._zmq_pub_socket = zmq.Context.instance().socket(zmq.PUB) self._zmq_pub_socket.setsockopt(zmq.SNDHWM, 0) diff --git a/lib/tfw/networking/server_connector.py b/lib/tfw/networking/server_connector.py index 88e9450..da407ac 100644 --- a/lib/tfw/networking/server_connector.py +++ b/lib/tfw/networking/server_connector.py @@ -10,7 +10,7 @@ from .serialization import serialize_tfw_msg, with_deserialize_tfw_msg LOG = logging.getLogger(__name__) -class ServerDownlinkConnector(): +class ServerDownlinkConnector: def __init__(self, connect_addr): self._zmq_sub_socket = zmq.Context.instance().socket(zmq.SUB) self._zmq_sub_socket.setsockopt(zmq.RCVHWM, 0) @@ -28,7 +28,7 @@ class ServerDownlinkConnector(): self._zmq_sub_stream.close() -class ServerUplinkConnector(): +class ServerUplinkConnector: def __init__(self, connect_addr): self._zmq_push_socket = zmq.Context.instance().socket(zmq.PUSH) self._zmq_push_socket.setsockopt(zmq.SNDHWM, 0)