From 357dae108a71a933949678824d0289c6220e5b57 Mon Sep 17 00:00:00 2001 From: Bryan Stitt Date: Thu, 14 Sep 2023 12:51:40 -0700 Subject: [PATCH] loop, dont crash --- web3_proxy/src/rpcs/one.rs | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/web3_proxy/src/rpcs/one.rs b/web3_proxy/src/rpcs/one.rs index d8de02a0..c2572b3e 100644 --- a/web3_proxy/src/rpcs/one.rs +++ b/web3_proxy/src/rpcs/one.rs @@ -852,7 +852,14 @@ impl Web3Rpc { } } } else { - unimplemented!(); + // TODO: what should we do here? + loop { + if *subscribe_stop_rx.borrow() { + trace!("stopping ws block subscription on {}", self); + return Ok(()); + } + subscribe_stop_rx.changed().await?; + } } Ok(())