Struct ntex_mqtt::v3::codec::Codec [−][src]
pub struct Codec { /* fields omitted */ }
Expand description
Mqtt v3.1.1 protocol codec
Implementations
Set max inbound frame size.
If max size is set to 0
, size is unlimited.
By default max size is set to 0
Set max inbound frame size.
If max size is set to 0
, size is unlimited.
By default max size is set to 0
Trait Implementations
type Error = DecodeError
type Error = DecodeError
The type of unrecoverable frame decoding errors. Read more
Attempts to decode a frame from the provided buffer of bytes.
fn decode_eof(
&self,
buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>
fn decode_eof(
&self,
buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>
A default method available to be called when there are no more bytes available to be read from the underlying I/O. Read more
Auto Trait Implementations
impl !RefUnwindSafe for Codec
impl UnwindSafe for Codec
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more