summaryrefslogtreecommitdiff
path: root/runtime
diff options
context:
space:
mode:
authorBartek Iwańczuk <biwanczuk@gmail.com>2024-10-24 18:43:24 +0100
committerGitHub <noreply@github.com>2024-10-24 18:43:24 +0100
commitb063cfecfe0479b1de14b8e9e06f1921ce830127 (patch)
tree7440d76ecc7abc9ee5412633461f0a6522904812 /runtime
parent9c80ddaf931db79ab4cbdf2262fa5b3f4da1e67f (diff)
Revert "fix(runtime): send ws ping frames from inspector server (#263… (#26513)
Diffstat (limited to 'runtime')
-rw-r--r--runtime/inspector_server.rs7
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;