p15670423
/
monkey
1
0
Fork 5
Code Issues Pull Requests 3 Projects Releases Wiki Activity

Common: Change IEventQueue and PyPubSubEventQueue's subscribe_tags() -> subscribe_tag()

This commit is contained in:
Shreya Malviya 2022-08-09 11:50:31 +05:30
parent e92d67bfe8
commit ae666d3dd3
2 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
monkey/common/event_queue/i_event_queue.py
View File

@ -33,11 +33,11 @@ class IEventQueue(ABC):
pass pass
@abstractstaticmethod @abstractstaticmethod
def subscribe_tags(tags: Sequence[str], subscriber: Callable[[AbstractEvent], None]): def subscribe_tag(tag: str, subscriber: Callable[[AbstractEvent], None]):
""" """
Subscribes a subscriber to all specified event tags Subscribes a subscriber to the specified event tag
:param tags: Event tags to which the subscriber should subscribe :param tag: Event tag to which the subscriber should subscribe
:param subscriber: Callable that should subscribe to events :param subscriber: Callable that should subscribe to events
""" """

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

@ -22,9 +22,8 @@ class PyPubSubEventQueue(IEventQueue):
pub.subscribe(listener=subscriber, topicName=event_type_name) pub.subscribe(listener=subscriber, topicName=event_type_name)
@staticmethod @staticmethod
def subscribe_tags(tags: Sequence[str], subscriber: Callable[[AbstractEvent], None]): def subscribe_tag(tag: str, subscriber: Callable[[AbstractEvent], None]):
for tag in tags: pub.subscribe(listener=subscriber, topicName=tag)
pub.subscribe(listener=subscriber, topicName=tag)
@staticmethod @staticmethod
def publish(event: AbstractEvent, data: Any = None): def publish(event: AbstractEvent, data: Any = None):