Struct ProcessSubscription 

pub struct ProcessSubscription<M: Send + 'static> { /* private fields */ }

A subscription that spawns and monitors an external process.

Captures stdout/stderr line-by-line and sends ProcessEvent messages. The process is killed when the subscription’s StopSignal fires or when the optional timeout expires.

Implementations

impl<M: Send + 'static> ProcessSubscription<M>

pub fn new( program: impl Into<String>, make_msg: impl Fn(ProcessEvent) -> M + Send + Sync + 'static, ) -> Self

Create a new process subscription for the given program.

The make_msg closure converts ProcessEvent into your model’s message type.

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

Add a command-line argument.

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

Add multiple command-line arguments.

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

Set an environment variable for the child process.

pub fn timeout(self, duration: Duration) -> Self

Set a timeout after which the process is killed.

pub fn with_id(self, id: SubId) -> Self

Override the subscription ID (for explicit deduplication control).

Trait Implementations

impl<M: Send + 'static> Subscription<M> for ProcessSubscription<M>

fn id(&self) -> SubId

Unique identifier for deduplication.

fn run(&self, sender: Sender<M>, stop: StopSignal)

Start the subscription, sending messages through the channel.