feat: DispatcherInterface.exec_result

src/graia/broadcast/__init__.py

@@ -188,7 +188,7 @@ async def Executor(
                 if i:
                     await run_always_await(i, dii, None, None)
 
-            result = await run_always_await(target_callable, **parameter_compile_result)
+            dii.exec_result.set_result(await run_always_await(target_callable, **parameter_compile_result))
         except (ExecutionStop, PropagationCancelled):
             raise
         except RequirementCrashed as e:
@@ -233,6 +233,7 @@ async def Executor(
 
             dii.ctx.reset(dii_token)
 
+        result = dii.exec_result.result()
         if result.__class__ is Force:
             return result.target
         elif result is RemoveMe:

src/graia/broadcast/interfaces/dispatcher.py

@@ -11,6 +11,7 @@
     Union,
 )
 
+from asyncio import Future
 from ..entities.event import Dispatchable
 from ..entities.signatures import Force
 from ..exceptions import ExecutionStop, RequirementCrashed
@@ -47,6 +48,7 @@ class DispatcherInterface(Generic[T_Event]):
     }
 
     ctx: "ClassVar[Ctx[DispatcherInterface]]" = Ctx("bcc_dii")
+    exec_result: Future[Any]
 
     broadcast: "Broadcast"
     dispatchers: List[T_Dispatcher]
@@ -66,6 +68,7 @@ def __init__(self, broadcast_instance: "Broadcast", dispatchers: List[T_Dispatch
         self.current_path = NestableIterable([])
         self.current_oplog = []
         self.success = set()
+        self.exec_result = Future()
         self._depth = depth
 
     @property