diff options
Diffstat (limited to 'ext')
| -rw-r--r-- | ext/websocket/Cargo.toml | 2 | ||||
| -rw-r--r-- | ext/websocket/lib.rs | 19 |
2 files changed, 10 insertions, 11 deletions
diff --git a/ext/websocket/Cargo.toml b/ext/websocket/Cargo.toml index 5aa668bfe..a4321b498 100644 --- a/ext/websocket/Cargo.toml +++ b/ext/websocket/Cargo.toml @@ -18,7 +18,7 @@ bytes.workspace = true deno_core.workspace = true deno_net.workspace = true deno_tls.workspace = true -fastwebsockets_06 = { package = "fastwebsockets", version = "0.6", features = ["upgrade", "unstable-split"] } +fastwebsockets.workspace = true h2_04 = { package = "h2", version = "0.4" } http-body-util = "0.1" http_1 = { package = "http", version = "1.0" } diff --git a/ext/websocket/lib.rs b/ext/websocket/lib.rs index ad1483f88..a5a1d80e4 100644 --- a/ext/websocket/lib.rs +++ b/ext/websocket/lib.rs @@ -54,13 +54,13 @@ use tokio::io::ReadHalf; use tokio::io::WriteHalf; use tokio::net::TcpStream; -use fastwebsockets_06::CloseCode; -use fastwebsockets_06::FragmentCollectorRead; -use fastwebsockets_06::Frame; -use fastwebsockets_06::OpCode; -use fastwebsockets_06::Role; -use fastwebsockets_06::WebSocket; -use fastwebsockets_06::WebSocketWrite; +use fastwebsockets::CloseCode; +use fastwebsockets::FragmentCollectorRead; +use fastwebsockets::Frame; +use fastwebsockets::OpCode; +use fastwebsockets::Role; +use fastwebsockets::WebSocket; +use fastwebsockets::WebSocketWrite; mod stream; @@ -175,7 +175,7 @@ async fn handshake_websocket( .header(CONNECTION, "Upgrade") .header( "Sec-WebSocket-Key", - fastwebsockets_06::handshake::generate_key(), + fastwebsockets::handshake::generate_key(), ); let user_agent = state.borrow().borrow::<WsUserAgent>().0.clone(); @@ -305,8 +305,7 @@ async fn handshake_connection< socket: S, ) -> Result<(WebSocket<WebSocketStream>, http_1::HeaderMap), AnyError> { let (upgraded, response) = - fastwebsockets_06::handshake::client(&LocalExecutor, request, socket) - .await?; + fastwebsockets::handshake::client(&LocalExecutor, request, socket).await?; let upgraded = upgraded.into_inner(); let stream = |