Struct MemoryTransport 

pub struct MemoryTransport { /* private fields */ }

In-memory transport using channels for message passing.

This transport enables direct communication between a client and server without any network or I/O overhead. Messages are passed through bounded MPSC channels.

Thread Safety

The transport is Send and can be passed to other threads, but it is not Sync. Each endpoint (client/server) should be used from a single thread at a time.

Cancellation

Recv operations poll the channel with a timeout, checking for cancellation between polls. This ensures proper integration with asupersync’s cancellation mechanism.

Implementations

impl MemoryTransport

pub fn with_poll_interval(self, interval: Duration) -> MemoryTransport

Sets the poll interval for cancellation checks during recv.

Lower values provide faster cancellation response but use more CPU. Default is 50ms.

pub fn is_closed(&self) -> bool

Returns whether this transport has been closed.

Trait Implementations

impl Debug for MemoryTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Transport for MemoryTransport

fn send( &mut self, cx: &Cx, message: &JsonRpcMessage, ) -> Result<(), TransportError>

Send a JSON-RPC message through this transport.

fn recv(&mut self, cx: &Cx) -> Result<JsonRpcMessage, TransportError>

Receive the next JSON-RPC message from this transport.

fn close(&mut self) -> Result<(), TransportError>

Close the transport gracefully.

fn send_request( &mut self, cx: &Cx, request: &JsonRpcRequest, ) -> Result<(), TransportError>

Send a request through this transport.

fn send_response( &mut self, cx: &Cx, response: &JsonRpcResponse, ) -> Result<(), TransportError>

Send a response through this transport.