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 prost and a provided struct implementing Message 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: Message + Default> Decoder for Codec<In, Out>

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: Message, Out> Encoder for Codec<In, Out>

type Item = 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.