Struct ProcessSpawner 

pub struct ProcessSpawner {
    pub program: String,
    pub args: Vec<String>,
    pub use_stdin: bool,
    pub stream_mode: Option<StreamMode>,
}

A SpawnerAdapter that runs a worker as an external OS process (a binary or a sh -c one-liner). Configured with the builder methods below, then registered like any other spawner.

Fields

program: String

Binary (or sh, when built via ProcessSpawner::run) to execute.

args: Vec<String>

Extra arguments passed to program, in order.

use_stdin: bool

Whether to pipe the directive into the child’s stdin — most LLM CLIs read prompts that way (--prompt - and friends). When false, the directive is appended to args instead.

stream_mode: Option<StreamMode>

Some(mode) — streaming mode. None — plain mode (the default).

Implementations

impl ProcessSpawner

pub fn new(program: impl Into<String>) -> Self

Builder entry point: spawn program with no args, stdin piping on, and plain mode.

pub fn arg(self, a: impl Into<String>) -> Self

Appends a single argument.

pub fn args(self, args: impl IntoIterator<Item = impl Into<String>>) -> Self

Appends multiple arguments at once.

pub fn use_stdin(self, v: bool) -> Self

Sets whether the directive/prompt is piped to the child’s stdin (true, the default) or appended as a trailing arg (false).

pub fn stream_mode(self, mode: StreamMode) -> Self

Set the streaming mode. Default: None (plain mode).

pub fn plain(self) -> Self

Reset to plain mode explicitly — sets stream_mode to None.

pub fn ndjson(self, v: bool) -> Self

Compatibility helper: ndjson(true) is equivalent to .stream_mode(StreamMode::NdjsonLines), and ndjson(false) to .plain(). A deprecation candidate, kept around for now.

pub fn run(cmd: impl Into<String>) -> Self

Convenience builder that runs a one-liner via sh -c '<cmd>'.

pub fn cmd(program: impl Into<String>) -> Self

Builder that spawns an arbitrary binary directly, without going through a shell.

Trait Implementations

impl SpawnerAdapter for ProcessSpawner

fn spawn<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, engine: &'life1 Engine, ctx: &'life2 Ctx, task_id: TaskId, attempt: u32, token: CapToken, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Worker>, SpawnError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Spawn one attempt as a worker. Returns Box<dyn Worker>.