Struct BinaryExecutor 

pub struct BinaryExecutor { /* private fields */ }

Spawn the objectiveai cli binary on disk, feed it the argv from request.into_command(), and stream each stdout JSONL line back as either a typed T or a structured crate::cli::Error.

The binary is resolved at execute time (not at construction). Resolution order:

• BinaryExecutor::from_path — returns the explicit path verbatim (used by tests pointing at an out-of-tree build).
• BinaryExecutor::new with Some(config_base_dir) — <config_base_dir>/objectiveai{.exe}.
• BinaryExecutor::new with None — <home>/.objectiveai/objectiveai{.exe}.

Implementations

impl BinaryExecutor

pub fn new(config_base_dir: Option<impl Into<PathBuf>>) -> Self

pub fn from_path(binary: impl Into<PathBuf>) -> Self

Construct an executor that spawns the binary at binary directly, regardless of file name. Skips the objectiveai name lookup so tests can target a target/debug/objectiveai-cli build without renaming or symlinking.

pub fn env(self, key: impl Into<String>, value: impl Into<String>) -> Self

Set an environment variable on every child the executor spawns. Stacks on top of the parent’s env; intended for tests that need to pin a per-instance CONFIG_BASE_DIR or OBJECTIVEAI_ADDRESS without racing other parallel tests via std::env::set_var.

Trait Implementations

impl CommandExecutor for BinaryExecutor

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: CommandResponse + DeserializeOwned + Send + 'static,

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

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