about summary refs log tree commit diff
path: root/tvix/glue/src/fetchers/decompression.rs
diff options
context:
space:
mode:
authorFlorian Klink <flokli@flokli.de>2024-06-12T15·20+0300
committerclbot <clbot@tvl.fyi>2024-06-13T21·07+0000
commit9d44da01ee4b889db26681a1f86922f3a5839f0c (patch)
treee8364d7503935b8a01f35d3706a0c97e05a7cad2 /tvix/glue/src/fetchers/decompression.rs
parentb992ca49a6dc1d1839e7a97b4a6f32a51e915482 (diff)
fix(tvix-glue/fetchers/decompression): propagate error with ? r/8266
Change-Id: I5e9d4f067f09307cb6f990ed6eca48345e2fb342
Reviewed-on: https://cl.tvl.fyi/c/depot/+/11810
Autosubmit: flokli <flokli@flokli.de>
Tested-by: BuildkiteCI
Reviewed-by: Brian Olsen <me@griff.name>
Diffstat (limited to '')
-rw-r--r--tvix/glue/src/fetchers/decompression.rs4
1 files changed, 1 insertions, 3 deletions
diff --git a/tvix/glue/src/fetchers/decompression.rs b/tvix/glue/src/fetchers/decompression.rs
index a11d324b1209..69a8297e6aa8 100644
--- a/tvix/glue/src/fetchers/decompression.rs
+++ b/tvix/glue/src/fetchers/decompression.rs
@@ -153,9 +153,7 @@ where
         };
 
         let mut our_buf = ReadBuf::new(buffer);
-        if let Err(e) = ready!(inner.as_pin_mut().unwrap().poll_read(cx, &mut our_buf)) {
-            return Poll::Ready(Err(e));
-        }
+        ready!(inner.as_pin_mut().unwrap().poll_read(cx, &mut our_buf))?;
 
         let data = our_buf.filled();
         if data.len() >= BYTES_NEEDED {