Struct IpcRpcServer

pub struct IpcRpcServer<U: UserMessage> { /* private fields */ }

Used to send messages to the connected client (assuming one does connect)

Implementations

impl<U: UserMessage> IpcRpcServer<U>

pub async fn initialize_server<F, Fut>( message_handler: F, ) -> Result<(ConnectionKey, IpcRpcServer<U>), IpcRpcError>

where F: Fn(U) -> Fut + Send + Sync + 'static, Fut: Future<Output = Option<U>> + Send,

Initializes a server and provides a ConnectionKey which clients can use to connect to it, even out of process.

pub fn send( &self, user_message: U, ) -> impl Future<Output = Result<U, IpcRpcError>> + Send + 'static

Sends a message, will give up on receiving a reply after the DEFAULT_REPLY_TIMEOUT has passed.

pub fn send_timeout( &self, user_message: U, timeout: Duration, ) -> impl Future<Output = Result<U, IpcRpcError>> + Send + 'static

Sends a message, waiting the given timeout for a reply.

pub fn client_connected(&self) -> bool

pub fn wait_for_client_to_connect( &mut self, ) -> impl Future<Output = Result<(), IpcRpcError>> + Send + 'static

pub fn wait_for_client_to_disconnect( &mut self, ) -> impl Future<Output = Result<(), IpcRpcError>> + Send + 'static

pub async fn schema_validated( &mut self, ) -> Result<SchemaValidationStatus, IpcRpcError>

Returns the outcome of automatic schema validation testing. This testing is performed on connection initiation.

Trait Implementations

impl<U: Clone + UserMessage> Clone for IpcRpcServer<U>

fn clone(&self) -> IpcRpcServer<U>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<U: Debug + UserMessage> Debug for IpcRpcServer<U>

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

Formats the value using the given formatter.

impl<U: UserMessage> Drop for IpcRpcServer<U>

fn drop(&mut self)

Executes the destructor for this type.