diff --git a/VERSION b/VERSION index 07776933..57c1ba4f 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -250611.0 +250612.0 diff --git a/crates/pulse_monitor/src/lib.rs b/crates/pulse_monitor/src/lib.rs index 14c4e67d..d2df059c 100644 --- a/crates/pulse_monitor/src/lib.rs +++ b/crates/pulse_monitor/src/lib.rs @@ -14,7 +14,7 @@ pub mod transport; // Note: Requires a stream that would immediately yield the initial cluster // state. -pub async fn run(mut cluster_stream: C) +pub async fn run(cluster_stream: C) where C: Stream>, { diff --git a/crates/rpc/src/lib.rs b/crates/rpc/src/lib.rs index 46b3e1ee..66b5e887 100644 --- a/crates/rpc/src/lib.rs +++ b/crates/rpc/src/lib.rs @@ -214,9 +214,6 @@ pub struct Error { } impl Error { - #[cfg(feature = "server")] - const THROTTLED: Self = Self::new(error_code::THROTTLED); - /// Creates a new RPC error with the provided error code. pub const fn new(code: &'static str) -> Self { Self { diff --git a/crates/rpc/src/quic/server.rs b/crates/rpc/src/quic/server.rs index 64bb2987..697c37dc 100644 --- a/crates/rpc/src/quic/server.rs +++ b/crates/rpc/src/quic/server.rs @@ -9,7 +9,7 @@ use { }, derive_more::derive::Deref, filter::{Filter, Permit, RejectionReason}, - futures::{FutureExt, SinkExt as _, TryFutureExt as _}, + futures::TryFutureExt as _, libp2p::{identity::Keypair, Multiaddr}, quinn::crypto::rustls::QuicServerConfig, std::{future::Future, io, net::SocketAddr, sync::Arc, time::Duration}, @@ -218,14 +218,6 @@ where let (tx, mut rx) = conn.accept_bi().await?; let Some(stream_permit) = self.acquire_stream_permit() else { - static THROTTLED_RESULT: &crate::Result<()> = &Err(crate::Error::THROTTLED); - - let (_, mut tx) = - BiDirectionalStream::new(tx, rx).upgrade::<(), crate::Result<()>, R::Codec>(); - - // The send buffer is large enough to write the whole response. - tx.send(THROTTLED_RESULT).now_or_never(); - continue; };