Refactored event brokers to use exit stacks

1 files changed, 8 insertions, 0 deletions

diff --git a/src/apscheduler/abc.py b/src/apscheduler/abc.py
index 9751293..e267836 100644
--- a/src/apscheduler/abc.py
+++ b/src/apscheduler/abc.py
@@ -105,6 +105,10 @@ class EventBroker(EventSource):
     def publish(self, event: events.Event) -> None:
         """Publish an event."""
 
+    @abstractmethod
+    def publish_local(self, event: events.Event) -> None:
+        """Publish an event, but only to local subscribers."""
+
 
 class AsyncEventBroker(EventSource):
     """
@@ -123,6 +127,10 @@ class AsyncEventBroker(EventSource):
     async def publish(self, event: events.Event) -> None:
         """Publish an event."""
 
+    @abstractmethod
+    async def publish_local(self, event: events.Event) -> None:
+        """Publish an event, but only to local subscribers."""
+
 
 class DataStore:
     def __enter__(self):