pub fn reader_ref<'a, R: AsyncRead + Unpin + Send>( reader: &'a mut R, ) -> Pin<Box<dyn Stream<Item = Result<Vec<u8>, Error>> + Send + 'a>>