fix: available in and output

op-rs · Jun 19, 2024 · ff4309a · ff4309a
1 parent a853592
commit ff4309a
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/crates/derive/src/stages/utils.rs b/crates/derive/src/stages/utils.rs
@@ -72,8 +72,11 @@ pub fn decompress_brotli(data: &[u8]) -> Result<Vec<u8>> {
                 tracing::warn!(target: "brotli", "Brotli decompression failed");
                 break;
             }
-            _ => continue,
-            // _ => tracing::debug!(target: "batch-reader", "decompressing brotli data"),
+            brotli::BrotliResult::NeedsMoreInput => tracing::debug!(target: "brotli", "Brotli needs more input, output: {:?}", output.slice()),
+            brotli::BrotliResult::NeedsMoreOutput => {
+                tracing::warn!(target: "brotli", "Brotli needs more output");
+                break;
+            }
         }
     }
     tracing::trace!(target: "brotli", "Written: {}", written);