Struct Codec

pub struct Codec<In, Out = In> { /* private fields */ }

Codec implements [Encoder] and [Decoder], uses [unsigned_varint]

to prefix messages with their length and uses [quick_protobuf] and a provided struct implementing [MessageRead] and [MessageWrite] to do the encoding.

Implementations

impl<In, Out> Codec<In, Out>

pub fn new(max_message_len_bytes: usize) -> Self

Create new Codec.

Parameter max_message_len_bytes determines the maximum length of the Protobuf message. The limit does not include the bytes needed for the [unsigned_varint].

Trait Implementations

impl<In, Out> Decoder for Codec<In, Out>

where Out: for<'a> MessageRead<'a>,

type Item = Out

The type of items returned by decode

type Error = Error

The type of decoding errors.

fn decode( &mut self, src: &mut BytesMut, ) -> Result<Option<Self::Item>, Self::Error>

Decode an item from the src BytesMut into an item

fn decode_eof( &mut self, src: &mut BytesMut, ) -> Result<Option<Self::Item>, Self::Error>

Called when the input stream reaches EOF, signaling a last attempt to decode

impl<In: MessageWrite, Out> Encoder for Codec<In, Out>

type Item<'a> = In

The type of items consumed by encode

type Error = Error

The type of encoding errors.

fn encode( &mut self, item: Self::Item<'_>, dst: &mut BytesMut, ) -> Result<(), Self::Error>

Encodes an item into the BytesMut provided by dst.