Struct WorkerProcess 

pub struct WorkerProcess { /* private fields */ }

Managed worker subprocess.

Implementations

impl WorkerProcess

pub async fn spawn( program: PathBuf, args: &[String], runtime: RuntimeKind, ) -> Result<Self>

Spawn a worker.

pub async fn request( &mut self, env: Envelope, wait: Duration, ) -> Result<Envelope>

Send a request and wait for a matching response.

pub async fn request_bounded( &mut self, env: Envelope, wait: Duration, max_message_bytes: u64, ) -> Result<Envelope>

Send a request with an explicit max response line size.

pub async fn shutdown(&mut self)

Graceful shutdown.