mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2025-09-01 17:23:48 +00:00
Code Issues Projects Releases Wiki Activity

Update to async-tungstenite 0.31

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/2448>
This commit is contained in:
Sebastian Dröge 2025-08-10 12:36:41 +03:00 committed by GStreamer Marge Bot
parent ece7013e71
commit d1b2c3a2e9
11 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
Cargo.lock generated
View file

@ -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",

2
audio/speechmatics/Cargo.toml
View file

@ -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"

2
audio/speechmatics/src/transcriber/imp.rs
View file

@ -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

2
net/webrtc/Cargo.toml
View file

@ -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"

2
net/webrtc/signalling/Cargo.toml
View file

@ -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"] }

2
net/webrtc/signalling/src/server/mod.rs
View file

@ -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 {

2
net/webrtc/src/aws_kvs_signaller/imp.rs
View file

@ -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

2
net/webrtc/src/janusvr_signaller/imp.rs
View file

@ -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

2
net/webrtc/src/signaller/imp.rs
View file

@ -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

2
utils/tracers/Cargo.toml
View file

@ -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"

2
utils/tracers/src/pipeline_snapshot/imp.rs
View file

@ -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