From 6c2fdcfd0acd30faa7be63d96ff3e11c0830b277 Mon Sep 17 00:00:00 2001 From: Thomas Eizinger Date: Wed, 14 Feb 2024 04:01:22 +1100 Subject: [PATCH] chore: bump Rust version to 1.76 (#3632) --- rust/gateway/src/eventloop.rs | 33 +++++++++++++++++---------------- rust/rust-toolchain.toml | 2 +- 2 files changed, 18 insertions(+), 17 deletions(-) diff --git a/rust/gateway/src/eventloop.rs b/rust/gateway/src/eventloop.rs index 86eeac03f..3d870d4f5 100644 --- a/rust/gateway/src/eventloop.rs +++ b/rust/gateway/src/eventloop.rs @@ -156,22 +156,23 @@ impl Eventloop { }) => { let tunnel = Arc::clone(&self.tunnel); - match self.connection_request_tasks.try_push( - (req.client.id, req.reference.clone()), - async move { - let conn = tunnel - .set_peer_connection_request( - req.client.payload, - req.client.peer.into(), - req.relays, - req.client.id, - req.expires_at, - req.resource, - ) - .await?; - Ok(GatewayResponse::ConnectionAccepted(conn)) - }, - ) { + let connection_request = async move { + let conn = tunnel + .set_peer_connection_request( + req.client.payload, + req.client.peer.into(), + req.relays, + req.client.id, + req.expires_at, + req.resource, + ) + .await?; + Ok(GatewayResponse::ConnectionAccepted(conn)) + }; + match self + .connection_request_tasks + .try_push((req.client.id, req.reference.clone()), connection_request) + { Err(futures_bounded::PushError::BeyondCapacity(_)) => { tracing::warn!("Too many connections requests, dropping existing one"); } diff --git a/rust/rust-toolchain.toml b/rust/rust-toolchain.toml index 7897a24d1..624eb0ea6 100644 --- a/rust/rust-toolchain.toml +++ b/rust/rust-toolchain.toml @@ -1,2 +1,2 @@ [toolchain] -channel = "1.75.0" +channel = "1.76.0"