Struct DeclaredCommandDispatcher 

pub struct DeclaredCommandDispatcher { /* private fields */ }

The dispatcher decorator that executes declared bodies at the server.

Wraps the production dispatcher. Consults the declared-body source before every dispatch; delegates untouched whenever the action carries no body.

Implementations

impl DeclaredCommandDispatcher

pub fn new( inner: Arc<dyn ActivityDispatcher>, bodies: DeclaredBodySource, attempts: DeclaredCommandAttempts, tokio: Handle, workspace_root: WorkspaceRoot, transcript: ActivityEventPublisher, ) -> Self

Wrap inner, consulting bodies before every dispatch, registering every attempt it executes in attempts so the run’s cancel can reach it, expanding {workspace_root} in declared commands with the server-resolved workspace_root, and streaming each executed command’s output onto transcript — the deployment’s one transcript sequencer, shared with every agent step.

attempts is required rather than optional because a dispatcher without one would execute commands nothing could stop, which is precisely the state this argument exists to end.

Trait Implementations

impl ActivityDispatcher for DeclaredCommandDispatcher

fn dispatch(&self, request: ActivityDispatch) -> Result<String, String>

Dispatch the activity and block until completion.

fn dispatch_async( self: Arc<Self>, request: ActivityDispatch, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send>>

Dispatch the activity from a Tokio task.

impl Debug for DeclaredCommandDispatcher

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.