Struct StdioTransport

pub struct StdioTransport { /* private fields */ }

Implementations

impl StdioTransport

pub fn new(read: Receiver<String>, write: Sender<String>) -> Self

Creates a new stdio transport instance using a child’s stdin/stdout.

Trait Implementations

impl Transport for StdioTransport

fn send<'life0, 'async_trait>( &'life0 self, message: Message, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends a message by writing it to the child process’ stdin

fn receive(&self) -> Pin<Box<dyn Stream<Item = Result<Message, Error>> + Send>>

Creates a stream of messages received from the child process’ stdout

Returns

Returns a pinned box containing a stream that yields Result<Message, Error>. The stream will continue until stdin is closed or an error occurs.

Message Flow

1. Messages are read from stdin in the background task created in new()
2. Each message is sent through the broadcast channel
3. This stream receives messages from the broadcast channel

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes the transport.

For stdio transport, this is a no-op as we don’t own stdin/stdout.

Returns

Always returns Ok(()).