Function into_codec_stream 

pub fn into_codec_stream<M, T>(
    rx: T,
) -> impl Stream<Item = Result<M, CodecError>> + Unpin + use<M, T>
where
    M: for<'de> Deserialize<'de> + 'static,
    T: AsyncRead + Unpin + 'static,

Returns a reader for your wire-protocol messages, automatically decoding byte-streams and handling the framing.