diff --git a/Cargo.lock b/Cargo.lock
index 382ca8d8c..1fb9f63eb 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -252,9 +252,9 @@ dependencies = [
 
 [[package]]
 name = "async-tungstenite"
-version = "0.30.0"
+version = "0.31.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e308e9866b891743e3fdf9dfd6b57f85c5062ca01ce4fed6f393e76eb5accea4"
+checksum = "ee88b4c88ac8c9ea446ad43498955750a4bbe64c4392f21ccfe5d952865e318f"
 dependencies = [
  "atomic-waker",
  "futures-core",
diff --git a/audio/speechmatics/Cargo.toml b/audio/speechmatics/Cargo.toml
index e5bca8183..2e8ff53d3 100644
--- a/audio/speechmatics/Cargo.toml
+++ b/audio/speechmatics/Cargo.toml
@@ -14,7 +14,7 @@ gst.workspace = true
 gst-base.workspace = true
 gst-audio = { workspace = true, features = ["v1_16"] }
 tokio = { version = "1", features = [ "full" ] }
-async-tungstenite = { version = "0.30", features = ["tokio", "tokio-runtime", "tokio-native-tls"] }
+async-tungstenite = { version = "0.31", features = ["tokio", "tokio-runtime", "tokio-native-tls"] }
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 atomic_refcell = "0.1"
diff --git a/audio/speechmatics/src/transcriber/imp.rs b/audio/speechmatics/src/transcriber/imp.rs
index 2ea614b84..ab064deec 100644
--- a/audio/speechmatics/src/transcriber/imp.rs
+++ b/audio/speechmatics/src/transcriber/imp.rs
@@ -1332,7 +1332,7 @@ impl Transcriber {
             gst::error_msg!(gst::CoreError::Failed, ["Failed to connect: {}", err])
         })?;
 
-        let (ws_sink, mut ws_stream) = ws.split();
+        let (mut ws_sink, mut ws_stream) = ws.split();
 
         let late_punctuation_factor = if settings.enable_late_punctuation_hack {
             2
diff --git a/net/webrtc/Cargo.toml b/net/webrtc/Cargo.toml
index d16b0922e..e36ddd99e 100644
--- a/net/webrtc/Cargo.toml
+++ b/net/webrtc/Cargo.toml
@@ -29,7 +29,7 @@ itertools = "0.14"
 tokio = { version = "1", features = ["fs", "macros", "rt-multi-thread", "time"] }
 tokio-native-tls = "0.3.0"
 tokio-stream = "0.1.11"
-async-tungstenite = { version = "0.30", features = ["tokio-runtime", "tokio-native-tls", "url"] }
+async-tungstenite = { version = "0.31", features = ["tokio-runtime", "tokio-native-tls", "url"] }
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 fastrand = "2.0"
diff --git a/net/webrtc/signalling/Cargo.toml b/net/webrtc/signalling/Cargo.toml
index 4023faa46..db1550f37 100644
--- a/net/webrtc/signalling/Cargo.toml
+++ b/net/webrtc/signalling/Cargo.toml
@@ -12,7 +12,7 @@ rust-version.workspace = true
 anyhow = "1"
 tokio = { version = "1", features = ["fs", "io-util", "macros", "rt-multi-thread", "time"] }
 tokio-native-tls = "0.3.0"
-async-tungstenite = { version = "0.30", features = ["tokio-runtime", "tokio-native-tls"] }
+async-tungstenite = { version = "0.31", features = ["tokio-runtime", "tokio-native-tls"] }
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 clap = { version = "4", features = ["derive"] }
diff --git a/net/webrtc/signalling/src/server/mod.rs b/net/webrtc/signalling/src/server/mod.rs
index 54b994adb..cc59774f4 100644
--- a/net/webrtc/signalling/src/server/mod.rs
+++ b/net/webrtc/signalling/src/server/mod.rs
@@ -135,7 +135,7 @@ impl Server {
         let (websocket_sender, mut websocket_receiver) = mpsc::channel::<String>(1000);
 
         let this_id_clone = this_id.clone();
-        let (ws_sink, mut ws_stream) = ws.split();
+        let (mut ws_sink, mut ws_stream) = ws.split();
         let send_task_handle = task::spawn(async move {
             let mut res = Ok(());
             loop {
diff --git a/net/webrtc/src/aws_kvs_signaller/imp.rs b/net/webrtc/src/aws_kvs_signaller/imp.rs
index a85df8466..6b2e767da 100644
--- a/net/webrtc/src/aws_kvs_signaller/imp.rs
+++ b/net/webrtc/src/aws_kvs_signaller/imp.rs
@@ -419,7 +419,7 @@ impl Signaller {
         gst::info!(CAT, imp = self, "connected");
 
         // Channel for asynchronously sending out websocket message
-        let (ws_sink, mut ws_stream) = ws.split();
+        let (mut ws_sink, mut ws_stream) = ws.split();
 
         // 1000 is completely arbitrary, we simply don't want infinite piling
         // up of messages as with unbounded
diff --git a/net/webrtc/src/janusvr_signaller/imp.rs b/net/webrtc/src/janusvr_signaller/imp.rs
index 92c177299..ed0bc39a4 100644
--- a/net/webrtc/src/janusvr_signaller/imp.rs
+++ b/net/webrtc/src/janusvr_signaller/imp.rs
@@ -347,7 +347,7 @@ impl Signaller {
         .await??;
 
         // Channel for asynchronously sending out websocket message
-        let (ws_sink, mut ws_stream) = ws.split();
+        let (mut ws_sink, mut ws_stream) = ws.split();
 
         // 1000 is completely arbitrary, we simply don't want infinite piling
         // up of messages as with unbounded
diff --git a/net/webrtc/src/signaller/imp.rs b/net/webrtc/src/signaller/imp.rs
index 4fb7dced7..d7f6d3c5e 100644
--- a/net/webrtc/src/signaller/imp.rs
+++ b/net/webrtc/src/signaller/imp.rs
@@ -207,7 +207,7 @@ impl Signaller {
         gst::info!(CAT, imp = self, "connected");
 
         // Channel for asynchronously sending out websocket message
-        let (ws_sink, mut ws_stream) = ws.split();
+        let (mut ws_sink, mut ws_stream) = ws.split();
 
         // 1000 is completely arbitrary, we simply don't want infinite piling
         // up of messages as with unbounded
diff --git a/utils/tracers/Cargo.toml b/utils/tracers/Cargo.toml
index d9b9113a4..cf16269b6 100644
--- a/utils/tracers/Cargo.toml
+++ b/utils/tracers/Cargo.toml
@@ -19,7 +19,7 @@ chrono = "0.4.35"
 walkdir = "2"
 tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
 tokio-stream = "0.1.11"
-async-tungstenite = { version = "0.30", features = ["tokio-runtime", "url"] }
+async-tungstenite = { version = "0.31", features = ["tokio-runtime", "url"] }
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 url = "2"
diff --git a/utils/tracers/src/pipeline_snapshot/imp.rs b/utils/tracers/src/pipeline_snapshot/imp.rs
index d93ef9e6a..28b374c10 100644
--- a/utils/tracers/src/pipeline_snapshot/imp.rs
+++ b/utils/tracers/src/pipeline_snapshot/imp.rs
@@ -450,7 +450,7 @@ impl PipelineSnapshot {
     ) -> Result<(), Box<dyn std::error::Error>> {
         let url = url::Url::parse(&host)?;
         let (ws_stream, _) = async_tungstenite::tokio::connect_async(url).await?;
-        let (write, mut read) = ws_stream.split();
+        let (mut write, mut read) = ws_stream.split();
 
         gst::debug!(CAT, "Connected to WebSocket server at {}", host);
         write