diff --git a/Cargo.lock b/Cargo.lock index 3855801a3..234a3a923 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1,6 +1,6 @@ # This file is automatically @generated by Cargo. # It is not intended for manual editing. -version = 3 +version = 4 [[package]] name = "addr2line" @@ -240,9 +240,9 @@ dependencies = [ [[package]] name = "async-tungstenite" -version = "0.25.0" +version = "0.28.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ef0f8d64ef9351752fbe5462f242c625d9c4910d2bc3f7ec44c43857ca123f5d" +checksum = "90e661b6cb0a6eb34d02c520b052daa3aa9ac0cc02495c9d066bbce13ead132b" dependencies = [ "async-native-tls", "async-std", @@ -251,7 +251,7 @@ dependencies = [ "futures-util", "log", "pin-project-lite", - "tungstenite 0.21.0", + "tungstenite 0.24.0", ] [[package]] @@ -3095,9 +3095,9 @@ dependencies = [ [[package]] name = "tungstenite" -version = "0.21.0" +version = "0.24.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "9ef1a641ea34f399a848dea702823bbecfb4c486f911735368f1f137cb8257e1" +checksum = "18e5b8366ee7a95b16d32197d0b2604b43a0be89dc5fac9f8e96ccafbaedda8a" dependencies = [ "byteorder", "bytes", @@ -3109,7 +3109,6 @@ dependencies = [ "rand", "sha1", "thiserror", - "url", "utf-8", ] diff --git a/livekit-api/Cargo.toml b/livekit-api/Cargo.toml index eab7df111..d74f9926a 100644 --- a/livekit-api/Cargo.toml +++ b/livekit-api/Cargo.toml @@ -100,8 +100,8 @@ optional = true [dependencies.async-tungstenite] optional = true -version = "0.25.0" -features = ["async-std-runtime", "async-native-tls"] +version = "0.28" +features = ["async-std-runtime", "async-tls"] [dependencies.futures-util] version = "0.3" diff --git a/livekit-api/src/signal_client/signal_stream.rs b/livekit-api/src/signal_client/signal_stream.rs index d738f459a..3ec4b669a 100644 --- a/livekit-api/src/signal_client/signal_stream.rs +++ b/livekit-api/src/signal_client/signal_stream.rs @@ -35,7 +35,7 @@ use async_tungstenite::{ async_std::connect_async, async_std::ClientStream as MaybeTlsStream, tungstenite::error::ProtocolError, - tungstenite::{Error as WsError, Message}, + tungstenite::{client::IntoClientRequest, Error as WsError, Message}, WebSocketStream, }; @@ -96,7 +96,7 @@ impl SignalStream { log::info!("connecting to {}", url); } - let (ws_stream, _) = connect_async(url).await?; + let (ws_stream, _) = connect_async(url.to_string().into_client_request()?).await?; let (ws_writer, ws_reader) = ws_stream.split(); let (emitter, events) = mpsc::unbounded_channel();