diff --git a/rusk/src/lib/http.rs b/rusk/src/lib/http.rs index 5e636b0399..1168c5dc25 100644 --- a/rusk/src/lib/http.rs +++ b/rusk/src/lib/http.rs @@ -483,6 +483,12 @@ async fn handle_stream_rues( loop { tokio::select! { + recv = stream.next() => { + if let Some(Ok(Message::Close(msg))) = recv { + let _ = stream.close(msg).await; + break; + } + } _ = shutdown.recv() => { let _ = stream.close(Some(CloseFrame { code: CloseCode::Away,