Struct LocalFakeServer

pub struct LocalFakeServer {
    pub from_client: Receiver<Vec<u8>>,
    pub to_client: Sender<Vec<u8>>,
    /* private fields */
}

Server type

Fields

from_client: Receiver<Vec<u8>>

from client to server

to_client: Sender<Vec<u8>>

from server to client

Implementations

impl LocalFakeServer

pub async fn recv_from_client(&mut self) -> Result<RpcFrame, LocalError>

receive a frame

pub async fn reply<E: Endpoint>( &mut self, seq_no: u32, data: &E::Response, ) -> Result<(), LocalError>

where E::Response: Serialize,

Reply

pub async fn publish<T: Topic>( &mut self, seq_no: u32, data: &T::Message, ) -> Result<(), LocalError>

where T::Message: Serialize,

Publish

pub fn cause_fatal_error(&self)

oops