@@ -237,15 +237,15 @@ def __init__(self, session: Session):
237237 def add_message_listener (self , listener : MessageListener ,
238238 uris : list [str ]) -> None :
239239 with self .__message_listeners_lock :
240- if listener in self .__message_listeners . keys () :
240+ if listener in self .__message_listeners :
241241 raise TypeError (
242242 "A listener for {} has already been added." .format (uris ))
243243 self .__message_listeners [listener ] = uris
244244 self .__message_listeners_lock .notify_all ()
245245
246246 def add_request_listener (self , listener : RequestListener , uri : str ):
247247 with self .__request_listeners_lock :
248- if uri in self .__request_listeners . keys () :
248+ if uri in self .__request_listeners :
249249 raise TypeError (
250250 "A listener for '{}' has already been added." .format (uri ))
251251 self .__request_listeners [uri ] = listener
@@ -289,7 +289,7 @@ def handle_message(self, obj: typing.Any) -> None:
289289 decoded_payloads = b""
290290 interesting = False
291291 with self .__message_listeners_lock :
292- for listener in self .__message_listeners . keys () :
292+ for listener in self .__message_listeners :
293293 dispatched = False
294294 keys = self .__message_listeners .get (listener )
295295 for key in keys :
@@ -320,7 +320,7 @@ def handle_request(self, obj: typing.Any) -> None:
320320 .format (mid , key , pid , sender , command ))
321321 interesting = False
322322 with self .__request_listeners_lock :
323- for mid_prefix in self .__request_listeners . keys () :
323+ for mid_prefix in self .__request_listeners :
324324 if mid .startswith (mid_prefix ):
325325 listener = self .__request_listeners .get (mid_prefix )
326326 interesting = True
0 commit comments