Struct MessageCodec 

pub struct MessageCodec { /* private fields */ }

Message codec for serialization/deserialization.

Implementations

impl MessageCodec

pub const DEFAULT_MAX_SIZE: usize

Default maximum message size (16 MB).

pub fn new() -> Self

Create a new codec with default settings.

pub fn with_max_size(max_size: usize) -> Self

Create a codec with a custom max size.

pub fn encode(&self, message: &Message) -> Result<Vec<u8>, CodecError>

Encode a message to bytes.

pub fn decode(&self, data: &[u8]) -> Result<Message, CodecError>

Decode a message from bytes.

pub fn read_message<R: Read>( &self, reader: &mut R, ) -> Result<Message, CodecError>

Read a framed message from a reader.

pub fn write_message<W: Write>( &self, writer: &mut W, message: &Message, ) -> Result<(), CodecError>

Write a framed message to a writer.

Trait Implementations

impl Clone for MessageCodec

fn clone(&self) -> MessageCodec

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MessageCodec

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

Formats the value using the given formatter.

impl Default for MessageCodec

fn default() -> Self

Returns the “default value” for a type.