Struct ResilientStdioTransport 

pub struct ResilientStdioTransport {
    inbound_rx: Receiver<RxJsonRpcMessage<RoleServer>>,
    outbound_tx: Arc<Mutex<Option<UnboundedSender<TxJsonRpcMessage<RoleServer>>>>>,
}

Resilient stdio transport — see module docs.

Fields

inbound_rx: Receiver<RxJsonRpcMessage<RoleServer>>

outbound_tx: Arc<Mutex<Option<UnboundedSender<TxJsonRpcMessage<RoleServer>>>>>

Wrapped in Arc<Mutex<>> so send() can return a 'static future per the Transport trait contract.

Implementations

impl ResilientStdioTransport

pub fn new<R, W>(read: R, write: W) -> Self

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

Spawn reader + writer tasks bound to the supplied I/O handles.

Generic over R / W so tests can inject in-memory pipes; production callers use resilient_stdio().

Trait Implementations

impl Transport<RoleServer> for ResilientStdioTransport

type Error = TransportError

fn send( &mut self, item: TxJsonRpcMessage<RoleServer>, ) -> impl Future<Output = Result<(), Self::Error>> + Send + 'static

Send a message to the transport

async fn receive(&mut self) -> Option<RxJsonRpcMessage<RoleServer>>

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

async fn close(&mut self) -> Result<(), Self::Error>

Close the transport

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