Struct PluginExecutor 

pub struct PluginExecutor { /* private fields */ }

Demultiplex many in-flight CommandRequest calls over a plugin’s stdin/stdout. Each execute mints a fresh id, emits a Output::Command(Command { id, command }) line on the plugin’s stdout, and returns a stream that yields whatever the overlord writes back to the plugin’s stdin under the same id.

Only one instance per process — the constructor consumes the global tokio::io::stdin() / stdout() handles.

Implementations

impl PluginExecutor

pub fn new() -> Self

Capture the plugin’s stdin/stdout and spawn the demuxer task.

Trait Implementations

impl CommandExecutor for PluginExecutor

type Error = Error

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

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

where R: CommandRequest + Send, T: CommandResponseTrait + DeserializeOwned + Send + 'static,

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

where R: CommandRequest + Send, T: CommandResponseTrait + 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.

impl Default for PluginExecutor

fn default() -> Self

Returns the “default value” for a type.