pub fn stream_frames_with_timeout<R: AsyncRead + Unpin>( input: R, timeout_duration: Duration ) -> impl Stream<Item = Result<Frame, Error>>