diff options
| author | Florian Klink <flokli@flokli.de> | 2024-06-12T15·20+0300 |
|---|---|---|
| committer | clbot <clbot@tvl.fyi> | 2024-06-13T21·07+0000 |
| commit | 9d44da01ee4b889db26681a1f86922f3a5839f0c (patch) | |
| tree | e8364d7503935b8a01f35d3706a0c97e05a7cad2 | |
| parent | b992ca49a6dc1d1839e7a97b4a6f32a51e915482 (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>
| -rw-r--r-- | tvix/glue/src/fetchers/decompression.rs | 4 |
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 { |