pub struct RuntimeEffectLocalExecutor<'run> { /* private fields */ }Expand description
Scoped local executor provided to a RuntimeEffectController for one effect.
Durable controllers may ignore it and replay their own recorded result. The
default inline controller delegates to it, so local provider/tool/checkpoint
work still crosses the same execute_effect boundary as durable controllers.
Implementations§
Source§impl<'run> RuntimeEffectLocalExecutor<'run>
impl<'run> RuntimeEffectLocalExecutor<'run>
pub fn sleep(cancellation: CancellationToken) -> Self
pub fn process_control(registry: Arc<dyn ProcessRegistry>) -> Self
pub async fn execute( self, envelope: RuntimeEffectEnvelope, ) -> Result<RuntimeEffectOutcome, RuntimeEffectControllerError>
pub fn into_process( self, ) -> Result<ProcessLocalExecution, RuntimeEffectControllerError>
Auto Trait Implementations§
impl<'run> !RefUnwindSafe for RuntimeEffectLocalExecutor<'run>
impl<'run> !Sync for RuntimeEffectLocalExecutor<'run>
impl<'run> !UnwindSafe for RuntimeEffectLocalExecutor<'run>
impl<'run> Freeze for RuntimeEffectLocalExecutor<'run>
impl<'run> Send for RuntimeEffectLocalExecutor<'run>
impl<'run> Unpin for RuntimeEffectLocalExecutor<'run>
impl<'run> UnsafeUnpin for RuntimeEffectLocalExecutor<'run>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more