Struct IpcClientSubscription

pub struct IpcClientSubscription {
    receiver: Receiver<IncomingMessage>,
    topic: Option<String>,
}

A subscription to receive messages over IPC. The subcription will start buffering messages after its creation and return them when receive() is called. Messages received before the subscription was created will not be returned.

Fields

receiver: Receiver<IncomingMessage>

topic: Option<String>

Implementations

impl IpcClientSubscription

pub async fn receive( &mut self, cancellation_token: Option<CancellationToken>, ) -> Result<IncomingMessage, ReceiveError>

Receive a message, optionally filtering by topic. Setting the cancellation_token to None will wait indefinitely.