Struct LocalTransport 

pub struct LocalTransport { /* private fields */ }

In-process transport that routes frames directly to a local eval site.

Sending a frame evaluates it against the site and buffers the reply for the next receive.

Implementations

impl LocalTransport

pub fn new(address: ServerAddress, site: Arc<dyn EvalSite>) -> Self

Creates a local transport for address backed by site.

Trait Implementations

impl Clone for LocalTransport

fn clone(&self) -> LocalTransport

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ConnectionTransport for LocalTransport

fn send_frame(&mut self, cx: &mut Cx, frame: ServerFrame) -> Result<()>

Sends one frame over the connection.

fn recv_frame( &mut self, _cx: &mut Cx, _timeout: Option<Duration>, ) -> Result<Option<ServerFrame>>

Receives one frame, returning None on timeout or end of stream.

fn close(&mut self, _cx: &mut Cx) -> Result<()>

Closes the connection.

fn as_any(&self) -> &dyn Any

Returns this connection as Any for downcasting.

fn serve_connection( &mut self, _runtime: &Arc<ServerRuntime>, _site: &Arc<dyn EvalSite>, ) -> Result<()>

Serves the connection server-side against site.

impl ServerTransport for LocalTransport

fn address(&self) -> &ServerAddress

Returns the address this transport is bound to.

fn accept(&self, _cx: &mut Cx) -> Result<Box<dyn ConnectionTransport>>

Blocks until a connection arrives and returns it.

fn shutdown(&self, _cx: &mut Cx) -> Result<()>

Shuts down the listener and releases its resources.

fn accept_timeout( &self, _cx: &mut Cx, _timeout: Duration, ) -> Result<Option<Box<dyn ConnectionTransport>>>

Accepts a connection, returning None if timeout elapses first.