pub fn decode(
version: EncoderVersion,
data: &[u8]
) -> Result<Option<TransportChunk>, CodecError>
Expand description
Decode transport data from a byte stream - if there’s a record batch present, return it, otherwise return None
.
pub fn decode(
version: EncoderVersion,
data: &[u8]
) -> Result<Option<TransportChunk>, CodecError>
Decode transport data from a byte stream - if there’s a record batch present, return it, otherwise return None
.