Merge pull request #103 from kokarare1212/deepsource-fix-3f1e7803
Iterate dictionary directly
This commit is contained in:
commit
414c8babeb
|
@ -237,7 +237,7 @@ class DealerClient(Closeable):
|
||||||
def add_message_listener(self, listener: MessageListener,
|
def add_message_listener(self, listener: MessageListener,
|
||||||
uris: list[str]) -> None:
|
uris: list[str]) -> None:
|
||||||
with self.__message_listeners_lock:
|
with self.__message_listeners_lock:
|
||||||
if listener in self.__message_listeners.keys():
|
if listener in self.__message_listeners:
|
||||||
raise TypeError(
|
raise TypeError(
|
||||||
"A listener for {} has already been added.".format(uris))
|
"A listener for {} has already been added.".format(uris))
|
||||||
self.__message_listeners[listener] = uris
|
self.__message_listeners[listener] = uris
|
||||||
|
@ -245,7 +245,7 @@ class DealerClient(Closeable):
|
||||||
|
|
||||||
def add_request_listener(self, listener: RequestListener, uri: str):
|
def add_request_listener(self, listener: RequestListener, uri: str):
|
||||||
with self.__request_listeners_lock:
|
with self.__request_listeners_lock:
|
||||||
if uri in self.__request_listeners.keys():
|
if uri in self.__request_listeners:
|
||||||
raise TypeError(
|
raise TypeError(
|
||||||
"A listener for '{}' has already been added.".format(uri))
|
"A listener for '{}' has already been added.".format(uri))
|
||||||
self.__request_listeners[uri] = listener
|
self.__request_listeners[uri] = listener
|
||||||
|
@ -289,7 +289,7 @@ class DealerClient(Closeable):
|
||||||
decoded_payloads = b""
|
decoded_payloads = b""
|
||||||
interesting = False
|
interesting = False
|
||||||
with self.__message_listeners_lock:
|
with self.__message_listeners_lock:
|
||||||
for listener in self.__message_listeners.keys():
|
for listener in self.__message_listeners:
|
||||||
dispatched = False
|
dispatched = False
|
||||||
keys = self.__message_listeners.get(listener)
|
keys = self.__message_listeners.get(listener)
|
||||||
for key in keys:
|
for key in keys:
|
||||||
|
@ -320,7 +320,7 @@ class DealerClient(Closeable):
|
||||||
.format(mid, key, pid, sender, command))
|
.format(mid, key, pid, sender, command))
|
||||||
interesting = False
|
interesting = False
|
||||||
with self.__request_listeners_lock:
|
with self.__request_listeners_lock:
|
||||||
for mid_prefix in self.__request_listeners.keys():
|
for mid_prefix in self.__request_listeners:
|
||||||
if mid.startswith(mid_prefix):
|
if mid.startswith(mid_prefix):
|
||||||
listener = self.__request_listeners.get(mid_prefix)
|
listener = self.__request_listeners.get(mid_prefix)
|
||||||
interesting = True
|
interesting = True
|
||||||
|
|
|
@ -168,8 +168,7 @@ class Packet:
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def parse(val: typing.Union[bytes, None]) -> typing.Union[bytes, None]:
|
def parse(val: typing.Union[bytes, None]) -> typing.Union[bytes, None]:
|
||||||
for cmd in [
|
for cmd in [
|
||||||
Packet.Type.__dict__[attr]
|
Packet.Type.__dict__[attr] for attr in Packet.Type.__dict__
|
||||||
for attr in Packet.Type.__dict__.keys()
|
|
||||||
if re.search("__.+?__", attr) is None
|
if re.search("__.+?__", attr) is None
|
||||||
and type(Packet.Type.__dict__[attr]) is bytes
|
and type(Packet.Type.__dict__[attr]) is bytes
|
||||||
]:
|
]:
|
||||||
|
|
Loading…
Reference in New Issue