Struct CliCommandExecutor 

pub struct CliCommandExecutor { /* private fields */ }

In-process executor. Owns a Context and dispatches each CommandRequest through the CLI’s local root dispatcher.

Implementations

impl CliCommandExecutor

pub fn new(ctx: Context) -> Self

Trait Implementations

impl CommandExecutor for CliCommandExecutor

type Error = Error

type Stream<T> = Pin<Box<dyn Stream<Item = Result<T, <CliCommandExecutor as CommandExecutor>::Error>> + Send>> where T: Send + 'static

async fn execute<R, T>( &self, request: R, agent_arguments: Option<&AgentArguments>, ) -> Result<Self::Stream<T>, Self::Error>

where R: CommandRequest + Send, T: CommandResponse + Serialize + DeserializeOwned + Send + 'static,

async fn execute_one<R, T>( &self, request: R, agent_arguments: Option<&AgentArguments>, ) -> Result<T, Self::Error>

where R: CommandRequest + Send, T: CommandResponse + Serialize + DeserializeOwned + Send + 'static,

Convenience for unary commands: run the request and resolve the first item from the stream. Implementations should error with their own “empty stream” variant if the stream closes without producing an item.