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.