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

Common: Rename _INTERNAL_ALL_EVENT_TYPES_TOPIC -> _ALL_EVENTS_TOPIC

This commit is contained in:
Mike Salvatore 2022-08-10 11:33:57 -04:00
parent a6c24af622
commit d151ce12fd
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -6,7 +6,7 @@ from common.events import AbstractEvent
from .i_event_queue import IEventQueue from .i_event_queue import IEventQueue
_INTERNAL_ALL_EVENT_TYPES_TOPIC = "internal_all_event_types" _ALL_EVENTS_TOPIC = "all_events_topic"
class PyPubSubEventQueue(IEventQueue): class PyPubSubEventQueue(IEventQueue):
@ -14,9 +14,7 @@ class PyPubSubEventQueue(IEventQueue):
self._pypubsub_publisher = pypubsub_publisher self._pypubsub_publisher = pypubsub_publisher
def subscribe_all_events(self, subscriber: Callable[[AbstractEvent], None]): def subscribe_all_events(self, subscriber: Callable[[AbstractEvent], None]):
self._pypubsub_publisher.subscribe( self._pypubsub_publisher.subscribe(listener=subscriber, topicName=_ALL_EVENTS_TOPIC)
listener=subscriber, topicName=_INTERNAL_ALL_EVENT_TYPES_TOPIC
)
def subscribe_type( def subscribe_type(
self, event_type: Type[AbstractEvent], subscriber: Callable[[AbstractEvent], None] self, event_type: Type[AbstractEvent], subscriber: Callable[[AbstractEvent], None]
@ -35,7 +33,7 @@ class PyPubSubEventQueue(IEventQueue):
self._publish_to_tags_topics(event) self._publish_to_tags_topics(event)
def _publish_to_all_events_topic(self, event: AbstractEvent): def _publish_to_all_events_topic(self, event: AbstractEvent):
self._pypubsub_publisher.sendMessage(_INTERNAL_ALL_EVENT_TYPES_TOPIC, event=event) self._pypubsub_publisher.sendMessage(_ALL_EVENTS_TOPIC, event=event)
def _publish_to_type_topic(self, event: AbstractEvent): def _publish_to_type_topic(self, event: AbstractEvent):
event_type_topic = PyPubSubEventQueue._get_type_topic(event.__class__) event_type_topic = PyPubSubEventQueue._get_type_topic(event.__class__)