Skip to content

Commit

Permalink
Removed unsupported type None
Browse files Browse the repository at this point in the history
  • Loading branch information
jrask committed Apr 9, 2024
1 parent e5785aa commit e9fcbf5
Showing 1 changed file with 8 additions and 6 deletions.
14 changes: 8 additions & 6 deletions python/remotivelabs-broker/remotivelabs/broker/sync/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -140,8 +140,8 @@ class Client:
def __init__(self, client_id: str = "broker_client"):
self._signal_creator: SignalCreator
self._traffic_stub: traffic_api_pb2_grpc.TrafficServiceStub
self._system_stub: system_api_pb2_grpc.SystemServiceStub = None
self._network_stub: network_api_pb2_grpc.NetworkServiceStub = None
self._system_stub: system_api_pb2_grpc.SystemServiceStub
self._network_stub: network_api_pb2_grpc.NetworkServiceStub
self._intercept_channel: grpc.Channel
self.client_id = client_id
self.url: Optional[str] = None
Expand All @@ -166,10 +166,12 @@ def connect(self, url: str, api_key: Union[str, None] = None):
if self.on_connect is not None:
self.on_connect(self)

def subscribe(self, signals_to_subscribe_to: Union[List[SignalIdentifier], List[str]],
on_signals: Optional[Callable[[SignalsInFrame], None]] = None,
changed_values_only: bool = True):

def subscribe(
self,
signals_to_subscribe_to: Union[List[SignalIdentifier], List[str]],
on_signals: Optional[Callable[[SignalsInFrame], None]] = None,
changed_values_only: bool = True,
):
client_id = br.common_pb2.ClientId(id="subscribe-sample")
if on_signals is None and self.on_signals is None:
raise BrokerException(
Expand Down

0 comments on commit e9fcbf5

Please sign in to comment.