Struct tower_kafka::transport::KafkaClientCodec
source · pub struct KafkaClientCodec { /* private fields */ }
Expand description
A simple wrapper around codec::LengthDelimitedCodec
, which ensures
protocol frames are well formed.
Implementations§
Trait Implementations§
source§impl Debug for KafkaClientCodec
impl Debug for KafkaClientCodec
source§impl Decoder for KafkaClientCodec
impl Decoder for KafkaClientCodec
source§fn decode(
&mut self,
src: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>
fn decode(
&mut self,
src: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>
Attempts to decode a frame from the provided buffer of bytes. Read more