pub fn decode_segment_stream<R: AsyncRead + Unpin + Send + 'static>( reader: R, ) -> impl Stream<Item = Result<WireEntry, Error>> + Send + 'static