fix: ensure stream is done

candlecorp · Oct 13, 2023 · b80b206 · b80b206
1 parent 496c902
commit b80b206
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/crates/wick/wick-trigger-http/src/http/component_utils.rs b/crates/wick/wick-trigger-http/src/http/component_utils.rs
@@ -183,6 +183,9 @@ pub(super) async fn respond(
     let (tx, rx) = unbounded_channel();
     let _output_handle = tokio::spawn(async move {
       while let Some(p) = body_stream.recv().await {
+        if !p.has_data() {
+          continue;
+        }
         match codec {
           Codec::Json => {
             let chunk = p