feat: Add dispatch_sequentially

cq/__init__.py

@@ -16,6 +16,7 @@
 from ._core.routing.di import DIAdapter
 from ._core.routing.dispatchers.abc import Dispatcher
 from ._core.routing.dispatchers.bus import Bus
+from ._core.routing.dispatchers.functions import dispatch_sequentially
 from ._core.routing.dispatchers.pipe import ContextPipeline, Pipe
 from ._core.routing.router import Router
 
@@ -46,6 +47,7 @@
     "Router",
     "__router__",
     "command_handler",
+    "dispatch_sequentially",
     "event_handler",
     "new_command_bus",
     "new_event_bus",

cq/_core/routing/dispatchers/functions.py

@@ -0,0 +1,11 @@
+from typing import Any
+
+from cq._core.routing.dispatchers.abc import Dispatcher
+
+
+async def dispatch_sequentially[T, *Ts](
+    dispatcher: Dispatcher[T, Any],
+    /,
+    *messages: T,
+) -> tuple[*Ts]:
+    return tuple([await dispatcher.dispatch(message) for message in messages])

tests/core/routing/dispatchers/test_functions.py

@@ -0,0 +1,21 @@
+from typing import Any, Self
+
+from cq import Bus, dispatch_sequentially
+
+
+async def test_dispatch_sequentially_with_success_return_tuple(
+    bus: Bus[Any, Any],
+) -> None:
+    class Handler:
+        async def handle(self, message: str) -> str:
+            return message
+
+        @classmethod
+        async def async_factory(cls) -> Self:
+            return cls()
+
+    bus.subscribe(str, Handler.async_factory)
+
+    messages = ("a", "b")
+    results: tuple[str, str] = await dispatch_sequentially(bus, *messages)
+    assert messages == results