aboutsummaryrefslogtreecommitdiff
path: root/src/io/mod.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/io/mod.rs')
-rw-r--r--src/io/mod.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/io/mod.rs b/src/io/mod.rs
index 8ce3ad6..fdad60b 100644
--- a/src/io/mod.rs
+++ b/src/io/mod.rs
@@ -804,11 +804,11 @@ pub trait AsyncBufReadExt: AsyncBufRead {
/// use futures::io::{AsyncBufReadExt, Cursor};
/// use futures::stream::StreamExt;
///
- /// let cursor = Cursor::new(b"lorem\nipsum\r\ndolor");
+ /// let cursor = Cursor::new(b"lorem\nipsum\xc2\r\ndolor");
///
- /// let mut lines_stream = cursor.lines().map(|l| l.unwrap());
+ /// let mut lines_stream = cursor.lines().map(|l| l.unwrap_or(String::from("invalid UTF_8")));
/// assert_eq!(lines_stream.next().await, Some(String::from("lorem")));
- /// assert_eq!(lines_stream.next().await, Some(String::from("ipsum")));
+ /// assert_eq!(lines_stream.next().await, Some(String::from("invalid UTF_8")));
/// assert_eq!(lines_stream.next().await, Some(String::from("dolor")));
/// assert_eq!(lines_stream.next().await, None);
/// # Ok::<(), Box<dyn std::error::Error>>(()) }).unwrap();