p59342861
/
monkey
forked from p15670423/monkey
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Common: Make methods static in PypubsubEventQueue

This commit is contained in:
Shreya Malviya 2022-08-08 12:07:45 +05:30
parent 414e8127ed
commit 1fbe9e5ad4
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
monkey/common/event_queue/pypubsub_event_queue.py
View File

@ -17,15 +17,18 @@ class PypubsubEventQueue(IEventQueue):
for event_type in types: for event_type in types:
PypubsubEventQueue._subscribe_type(event_type, subscriber) PypubsubEventQueue._subscribe_type(event_type, subscriber)
@staticmethod
def _subscribe_type(event_type: AbstractEvent, subscriber: Callable[..., Any]): def _subscribe_type(event_type: AbstractEvent, subscriber: Callable[..., Any]):
# pypubsub.pub.subscribe needs a string as the topic/event name # pypubsub.pub.subscribe needs a string as the topic/event name
event_type_name = event_type.__name__ event_type_name = event_type.__name__
pub.subscribe(listener=subscriber, topicName=event_type_name) pub.subscribe(listener=subscriber, topicName=event_type_name)
def subscribe_tags(self, tags: Sequence[str], subscriber: Callable[..., Any]): @staticmethod
def subscribe_tags(tags: Sequence[str], subscriber: Callable[..., Any]):
for tag in tags: for tag in tags:
PypubsubEventQueue._subscribe_tag(tag, subscriber) PypubsubEventQueue._subscribe_tag(tag, subscriber)
@staticmethod
def _subscribe_tag(tag: str, subscriber: Callable[..., Any]): def _subscribe_tag(tag: str, subscriber: Callable[..., Any]):
pub.subscribe(listener=subscriber, topicName=tag) pub.subscribe(listener=subscriber, topicName=tag)