Struct IpcRpc

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

Initializes a server and owns the connected client. This structure is the preferred way for servers to manage a relationship with a client.

Fields

server: IpcRpcServer<U>

Implementations

impl<U: UserMessage> IpcRpc<U>

pub fn build() -> IpcRpcBuilder<U>

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 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: Debug + UserMessage> Debug for IpcRpc<U>

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

Formats the value using the given formatter.

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

fn drop(&mut self)

Executes the destructor for this type.