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

Common: Rename IEventQueue -> IAgentEventQueue

This commit is contained in:
Shreya Malviya 2022-09-05 19:09:47 +05:30
parent f577e48d72
commit 903d43fe26
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
monkey/common/event_queue/__init__.py
View File

@ -1,3 +1,3 @@
from .types import EventSubscriber from .types import EventSubscriber
from .i_event_queue import IEventQueue from .i_event_queue import IAgentEventQueue
from .pypubsub_event_queue import PyPubSubEventQueue from .pypubsub_event_queue import PyPubSubEventQueue

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

@ -6,7 +6,7 @@ from common.events import AbstractAgentEvent
from . import EventSubscriber from . import EventSubscriber
class IEventQueue(ABC): class IAgentEventQueue(ABC):
""" """
Manages subscription and publishing of events Manages subscription and publishing of events
""" """

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

@ -5,14 +5,14 @@ from pubsub.core import Publisher
from common.events import AbstractAgentEvent from common.events import AbstractAgentEvent
from . import EventSubscriber, IEventQueue from . import EventSubscriber, IAgentEventQueue
_ALL_EVENTS_TOPIC = "all_events_topic" _ALL_EVENTS_TOPIC = "all_events_topic"
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
class PyPubSubEventQueue(IEventQueue): class PyPubSubEventQueue(IAgentEventQueue):
def __init__(self, pypubsub_publisher: Publisher): def __init__(self, pypubsub_publisher: Publisher):
self._pypubsub_publisher = pypubsub_publisher self._pypubsub_publisher = pypubsub_publisher
self._refs = [] self._refs = []