Bubble up I/O errors in encode_stream_ascii

benches/bench.rs

@@ -19,7 +19,7 @@ fn ascii_benchmark(c: &mut Criterion) {
     group.bench_function("stream", |b| {
         b.iter(|| {
             f.rewind().unwrap();
-            encode_stream_ascii(&mut f, &mut devnull);
+            encode_stream_ascii(&mut f, &mut devnull).unwrap();
         })
     });
 

src/encode_ascii.rs

@@ -87,26 +87,30 @@ pub fn encode_string_ascii(input: &[u8]) -> String {
 ///     ripmors::encode_stream_ascii(&mut stdin, &mut stdout);
 /// }
 /// ```
-pub fn encode_stream_ascii(input: &mut impl Read, output: &mut impl Write) {
+pub fn encode_stream_ascii(
+    input: &mut impl Read,
+    output: &mut impl Write,
+) -> Result<(), std::io::Error> {
     let mut input_buf = vec![0u8; 1 << 15];
     let mut output_buf = Vec::new();
     loop {
-        let bytes_read = input.read(&mut input_buf).unwrap();
+        let bytes_read = input.read(&mut input_buf)?;
         if bytes_read == 0 {
             break;
         }
         encode_buffer_ascii(&input_buf[..bytes_read], &mut output_buf);
         if output_buf.is_empty() {
         } else if output_buf.last() == Some(&b' ') {
             output_buf.pop();
-            output.write_all(&output_buf).unwrap();
+            output.write_all(&output_buf)?;
             output_buf.clear();
             output_buf.push(b' ');
         } else {
-            output.write_all(&output_buf).unwrap();
+            output.write_all(&output_buf)?;
             output_buf.clear();
         }
     }
+    Ok(())
 }
 
 #[test]

src/main.rs

@@ -50,7 +50,7 @@ fn main() {
         };
         decode_stream(&mut stdin, &mut stdout, char_decode);
     } else if args.encode == Some(EncodeVariant::Ascii) {
-        encode_stream_ascii(&mut stdin, &mut stdout);
+        encode_stream_ascii(&mut stdin, &mut stdout).unwrap();
     } else {
         encode_stream(&mut stdin, &mut stdout);
     }

tests/tests.rs

@@ -28,7 +28,7 @@ fn compare_output_to_oracle(writer: BufWriter<Vec<u8>>, expected_filename: &str)
 fn test_encode_stream_ascii() {
     let mut f = std::fs::File::open("1-original.txt").unwrap();
     let mut writer = BufWriter::new(Vec::new());
-    encode_stream_ascii(&mut f, &mut writer);
+    encode_stream_ascii(&mut f, &mut writer).unwrap();
     compare_output_to_oracle(writer, "2-encoded.txt");
 }