diff --git a/crates/wick/wick-trigger-http/src/http/component_utils.rs b/crates/wick/wick-trigger-http/src/http/component_utils.rs index d9d8bcbb..4edea58d 100644 --- 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