Struct IpcClient

pub struct IpcClient<Crypto, Com, Ses>
where
    Crypto: CryptoProvider<Com, Ses>,
    Com: CommunicationBackend,
    Ses: SessionRepository<Session = Crypto::Session>,
{
    crypto: Crypto,
    communication: Com,
    sessions: Ses,
}

Fields

crypto: Crypto

communication: Com

sessions: Ses

Implementations

impl<Crypto, Com, Ses> IpcClient<Crypto, Com, Ses>

where Crypto: CryptoProvider<Com, Ses>, Com: CommunicationBackend, Ses: SessionRepository<Session = Crypto::Session>,

pub fn new(crypto: Crypto, communication: Com, sessions: Ses) -> Self

pub async fn send( &self, message: OutgoingMessage, ) -> Result<(), SendError<Crypto::SendError, Com::SendError>>

Send a message

pub async fn receive( &self, topic: Option<String>, timeout: Option<Duration>, ) -> Result<IncomingMessage, ReceiveError<Crypto::ReceiveError, Com::ReceiveError>>

Receive a message, optionally filtering by topic. Setting the topic to None will receive all messages. Setting the timeout to None will wait indefinitely.

pub async fn receive_typed<Payload>( &self, timeout: Option<Duration>, ) -> Result<TypedIncomingMessage<Payload>, TypedReceiveError<<Payload as TryFrom<Vec<u8>>>::Error, Crypto::ReceiveError, Com::ReceiveError>>

where Payload: TryFrom<Vec<u8>> + PayloadTypeName,

Receive a message, skipping any messages that cannot be deserialized into the expected payload type.