We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 851159a commit c9ce04cCopy full SHA for c9ce04c
src/frequenz/dispatch/__init__.py
@@ -9,7 +9,11 @@
9
10
from frequenz.dispatch.actor import DispatchActor, DispatchEvent
11
12
-__all__ = ["Dispatcher"]
+DispatchReceiver = Receiver[Dispatch]
13
+"""Type alias for a dispatch receiver."""
14
+
15
+DispatchEventReceiver = Receiver[DispatchEvent]
16
+"""Type alias for a dispatch event receiver."""
17
18
19
class Dispatcher:
@@ -57,6 +61,15 @@ def __init__(
57
61
self._ready_channel.new_sender(),
58
62
)
59
63
64
+ @property
65
+ def actor(self) -> DispatchActor:
66
+ """Return the actor.
67
68
+ Returns:
69
+ The actor.
70
+ """
71
+ return self._actor
72
60
73
async def start(self) -> None:
74
"""Start the actor."""
75
self._actor.start()
0 commit comments