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. The struct is Clone so callers that need a second handle can share without an outer Arc: every field is already behind Arc, including counter, so clones share the id sequence and pending map.

Implementations

impl PluginExecutor

pub fn new() -> Self

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

Trait Implementations

impl Clone for PluginExecutor

fn clone(&self) -> PluginExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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 + Serialize + 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 + 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.

impl Default for PluginExecutor

fn default() -> Self

Returns the “default value” for a type.