Struct AsyncMessageCodec 

pub struct AsyncMessageCodec<S: AsyncRead + AsyncWrite + Send + Unpin> { /* private fields */ }

A codec for reading and writing length-value encoded messages.

Implementations

impl<S: AsyncRead + AsyncWrite + Send + Unpin> AsyncMessageCodec<S>

pub fn new(stream: S) -> Self

pub fn get_stream(&mut self) -> &mut S

pub async fn read_message(&mut self) -> Result<Bytes>

Reads a whole length-value encoded message from the underlying reader. Returns the message bytes as a Vec<u8>.

pub async fn write_message<T: Message>(&mut self, message: T) -> Result<()>

Writes a length-value encoded message to the underlying writer.

Trait Implementations

impl<S: Debug + AsyncRead + AsyncWrite + Send + Unpin> Debug for AsyncMessageCodec<S>

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

Formats the value using the given formatter.