Trait fluvio_protocol_core::Decoder[][src]

pub trait Decoder: Sized + Default {
    fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error>
    where
        T: Buf
; fn decode_from<T>(src: &mut T, version: Version) -> Result<Self, Error>
    where
        T: Buf,
        Self: Default
, { ... } }

Required methods

Provided methods

decode Kafka compliant protocol values from buf

Implementations on Foreign Types

Implementors