summaryrefslogtreecommitdiff
path: root/ext/node/ops/http.rs
diff options
context:
space:
mode:
Diffstat (limited to 'ext/node/ops/http.rs')
-rw-r--r--ext/node/ops/http.rs1
1 files changed, 1 insertions, 0 deletions
diff --git a/ext/node/ops/http.rs b/ext/node/ops/http.rs
index 4b1f99ec0..773902ded 100644
--- a/ext/node/ops/http.rs
+++ b/ext/node/ops/http.rs
@@ -272,6 +272,7 @@ pub async fn op_node_http_fetch_response_upgrade(
loop {
let read = upgraded_rx.read(&mut buf).await?;
if read == 0 {
+ read_tx.shutdown().await?;
break;
}
read_tx.write_all(&buf[..read]).await?;