Struct TokioChildProcess 

pub struct TokioChildProcess { /* private fields */ }

Implementations

impl TokioChildProcess

pub fn new(command: impl Into<CommandWrap>) -> Result<TokioChildProcess, Error>

Convenience: spawn with default piped stdio

pub fn builder(command: impl Into<CommandWrap>) -> TokioChildProcessBuilder

Builder entry-point allowing fine-grained stdio control.

pub fn id(&self) -> Option<u32>

Get the process ID of the child process.

pub async fn graceful_shutdown(&mut self) -> Result<(), Error>

Gracefully shutdown the child process

This will first close the transport to the child process (the server), and wait for the child process to exit normally with a timeout. If the child process doesn’t exit within the timeout, it will be killed.

pub fn into_inner(self) -> Option<Box<dyn ChildWrapper>>

Take ownership of the inner child process

pub fn split(self) -> (TokioChildProcessOut, ChildStdin)

👎Deprecated since 0.5.0:

use the Transport trait implementation instead

Split this helper into a reader (stdout) and writer (stdin).

Trait Implementations

impl Transport<RoleClient> for TokioChildProcess

type Error = Error

fn send( &mut self, item: JsonRpcMessage<<RoleClient as ServiceRole>::Req, <RoleClient as ServiceRole>::Resp, <RoleClient as ServiceRole>::Not>, ) -> impl Future<Output = Result<(), <TokioChildProcess as Transport<RoleClient>>::Error>> + Send + 'static

Send a message to the transport

fn receive( &mut self, ) -> impl Future<Output = Option<JsonRpcMessage<<RoleClient as ServiceRole>::PeerReq, <RoleClient as ServiceRole>::PeerResp, <RoleClient as ServiceRole>::PeerNot>>> + Send

Receive a message from the transport, this operation is sequential.

fn close( &mut self, ) -> impl Future<Output = Result<(), <TokioChildProcess as Transport<RoleClient>>::Error>> + Send

Close the transport

fn name() -> Cow<'static, str>