diff options
author | Bartek Iwańczuk <biwanczuk@gmail.com> | 2024-10-24 18:43:24 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-10-24 18:43:24 +0100 |
commit | b063cfecfe0479b1de14b8e9e06f1921ce830127 (patch) | |
tree | 7440d76ecc7abc9ee5412633461f0a6522904812 /runtime/inspector_server.rs | |
parent | 9c80ddaf931db79ab4cbdf2262fa5b3f4da1e67f (diff) |
Revert "fix(runtime): send ws ping frames from inspector server (#263… (#26513)
Diffstat (limited to 'runtime/inspector_server.rs')
-rw-r--r-- | runtime/inspector_server.rs | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/runtime/inspector_server.rs b/runtime/inspector_server.rs index 33b2ab872..1f8cd5e71 100644 --- a/runtime/inspector_server.rs +++ b/runtime/inspector_server.rs @@ -23,7 +23,6 @@ use deno_core::InspectorSessionProxy; use deno_core::JsRuntime; use fastwebsockets::Frame; use fastwebsockets::OpCode; -use fastwebsockets::Payload; use fastwebsockets::WebSocket; use hyper::body::Bytes; use hyper_util::rt::TokioIo; @@ -34,7 +33,6 @@ use std::pin::pin; use std::process; use std::rc::Rc; use std::thread; -use std::time::Duration; use tokio::net::TcpListener; use tokio::sync::broadcast; use uuid::Uuid; @@ -395,13 +393,8 @@ async fn pump_websocket_messages( inbound_tx: UnboundedSender<String>, mut outbound_rx: UnboundedReceiver<InspectorMsg>, ) { - let mut ticker = tokio::time::interval(Duration::from_secs(30)); - 'pump: loop { tokio::select! { - _ = ticker.tick() => { - let _ = websocket.write_frame(Frame::new(true, OpCode::Ping, None, Payload::Borrowed(&[]))).await; - } Some(msg) = outbound_rx.next() => { let msg = Frame::text(msg.content.into_bytes().into()); let _ = websocket.write_frame(msg).await; |