diff --git a/src/transport.rs b/src/transport.rs index 3c2b9a3..a4c4cb0 100644 --- a/src/transport.rs +++ b/src/transport.rs @@ -462,6 +462,8 @@ async fn propagate_read( } } + let _ = ws_tx.write_frame(Frame::close(1000, &[])).await; + Ok(()) }