Struct async_io_converse::ReceivedMessage

pub struct ReceivedMessage<W: AsyncWrite + Unpin, T: Serialize + DeserializeOwned + Unpin> { /* private fields */ }

A message received from the connected peer, which you may choose to reply to.

Implementations

impl<W: AsyncWrite + Unpin, T: Serialize + DeserializeOwned + Unpin> ReceivedMessage<W, T>

pub fn message(&self) -> &T

Peeks at the message, panicking if the message had already been taken prior.

pub fn message_opt(&self) -> Option<&T>

Peeks at the message, returning None if the message had already been taken prior.

pub fn take_message(&mut self) -> T

Pulls the message from this, panicking if the message had already been taken prior.

pub fn take_message_opt(&mut self) -> Option<T>

Pulls the message from this, returning None if the message had already been taken prior.

pub async fn reply(self, reply: T) -> Result<(), Error>

Sends the given message as a reply to this one. There are two ways for the peer to receive this reply

1. .await both layers of AsyncWriteConverse::send or AsyncWriteConverse::send_timeout
2. They’ll receive it as the return value of AsyncWriteConverse::ask or AsyncWriteConverse::ask_timeout.