Function read_frame 

pub fn read_frame<T: Schema>(r: &mut impl Read) -> Result<Option<T>>

The next message; None where the stream ends between frames.