Struct Codec

pub struct Codec { /* private fields */ }

Mqtt v3.1.1 protocol codec

Implementations

impl Codec

pub fn new() -> Self

Create Codec instance

pub fn set_max_size(&self, size: u32)

Set max inbound frame size.

If max size is set to 0, size is unlimited. By default max size is set to 0

pub fn set_min_chunk_size(&self, size: u32)

Set min payload chunk size.

If the minimum size is set to 0, incoming payload chunks will be processed immediately. Otherwise, the codec will accumulate chunks until the total size reaches the specified minimum. By default min size is set to 0

Trait Implementations

impl Clone for Codec

fn clone(&self) -> Codec

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Codec

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

Formats the value using the given formatter.

impl Decoder for Codec

type Item = Decoded

The type of decoded frames.

type Error = DecodeError

The type of unrecoverable frame decoding errors.

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

Attempts to decode a frame from the provided buffer of bytes.

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

Attempts to decode a frame from the provided buffer of bytes.

impl Default for Codec

fn default() -> Self

Returns the “default value” for a type.

impl Encoder for Codec

type Item = Encoded

The type of items consumed by the Encoder

type Error = EncodeError

The type of encoding errors.

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

Encodes a frame into the buffer provided.

fn encode_vec( &self, item: Self::Item, dst: &mut BytesVec, ) -> Result<(), Self::Error>

Encodes a frame into the buffer provided.