Struct StdioTransport 

pub struct StdioTransport { /* private fields */ }

Stdio transport for JSON-RPC communication

Supports two modes:

1. Native mode: Uses process stdin/stdout directly
2. Child mode: Communicates with a spawned child process

Implementations

impl StdioTransport

pub fn new() -> Self

Create a new stdio transport using stdin/stdout

This is used for server-side communication where the process reads from stdin and writes to stdout.

pub fn with_config(config: TransportConfig) -> Self

Create a new stdio transport with custom configuration

pub fn from_streams<R, W>(reader: R, writer: W, config: TransportConfig) -> Self

where R: AsyncRead + Send + Unpin + 'static, W: AsyncWrite + Send + Unpin + 'static,

Create a stdio transport from async read/write streams

Wraps the reader in a BufReader for efficient reading.

pub async fn spawn_child(command: &mut Command) -> Result<Self>

Spawn a child process and create a transport to communicate with it

The child process should implement the JSON-RPC protocol over stdio.

pub async fn spawn_child_with_config( command: &mut Command, config: TransportConfig, ) -> Result<Self>

Spawn a child process with custom configuration

pub fn with_tokio_stdio() -> Self

Initialize with tokio stdin/stdout

Must be called within a tokio runtime context.

pub fn child(&mut self) -> Option<&mut Child>

Get the child process if this transport was created via spawn_child

pub fn is_child_running(&mut self) -> bool

Check if there’s a child process and if it’s still running

pub async fn wait_child(&mut self) -> Result<Option<ExitStatus>>

Wait for the child process to exit and return its status

Trait Implementations

impl Default for StdioTransport

fn default() -> Self

Returns the “default value” for a type.

impl Transport for StdioTransport

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

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

Send a message through the transport

fn receive<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<JsonRpcMessage>>> + Send + 'async_trait>>

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

Receive a message from the transport

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

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

Close the transport

fn is_closed(&self) -> bool

Check if the transport is closed