Update to new tungstenite and bump version

CHANGELOG.md

@@ -1,3 +1,7 @@
+# 0.25.0
+
+- Update `tungstenite` to `0.25.0` ([important updates!](https://github.com/snapview/tungstenite-rs/blob/master/CHANGELOG.md#0250)).
+
 # 0.24.0
 
 - Update dependencies (TLS, tungstenite).

Cargo.toml

@@ -6,9 +6,9 @@ keywords = ["websocket", "io", "web"]
 authors = ["Daniel Abramov <[email protected]>", "Alexey Galakhov <[email protected]>"]
 license = "MIT"
 homepage = "https://github.com/snapview/tokio-tungstenite"
-documentation = "https://docs.rs/tokio-tungstenite/0.24.0"
+documentation = "https://docs.rs/tokio-tungstenite/0.25.0"
 repository = "https://github.com/snapview/tokio-tungstenite"
-version = "0.24.0"
+version = "0.25.0"
 edition = "2018"
 rust-version = "1.63"
 include = ["examples/**/*", "src/**/*", "LICENSE", "README.md", "CHANGELOG.md"]
@@ -34,7 +34,7 @@ futures-util = { version = "0.3.28", default-features = false, features = ["sink
 tokio = { version = "1.0.0", default-features = false, features = ["io-util"] }
 
 [dependencies.tungstenite]
-version = "0.24.0"
+version = "0.25.0"
 default-features = false
 
 [dependencies.native-tls-crate]

examples/autobahn-client.rs

@@ -11,7 +11,7 @@ async fn get_case_count() -> Result<u32> {
     let (mut socket, _) = connect_async("ws://localhost:9001/getCaseCount").await?;
     let msg = socket.next().await.expect("Can't fetch case count")?;
     socket.close(None).await?;
-    Ok(msg.into_text()?.parse::<u32>().expect("Can't parse case count"))
+    Ok(msg.to_text()?.parse::<u32>().expect("Can't parse case count"))
 }
 
 async fn update_reports() -> Result<()> {

examples/client.rs

@@ -33,7 +33,7 @@ async fn main() {
     let ws_to_stdout = {
         read.for_each(|message| async {
             let data = message.unwrap().into_data();
-            tokio::io::stdout().write_all(&data).await.unwrap();
+            tokio::io::stdout().write_all(&data.as_slice()).await.unwrap();
         })
     };
 

examples/interval-server.rs

@@ -40,7 +40,7 @@ async fn handle_connection(peer: SocketAddr, stream: TcpStream) -> Result<()> {
                 }
             }
             _ = interval.tick() => {
-                ws_sender.send(Message::Text("tick".to_owned())).await?;
+                ws_sender.send(Message::text("tick")).await?;
             }
         }
     }

tests/communication.rs

@@ -55,7 +55,7 @@ async fn communication() {
 
     for i in 1..10 {
         info!("Sending message");
-        stream.send(Message::Text(format!("{}", i))).await.expect("Failed to send message");
+        stream.send(Message::text(format!("{}", i))).await.expect("Failed to send message");
     }
 
     stream.close(None).await.expect("Failed to close");
@@ -95,7 +95,7 @@ async fn split_communication() {
 
     for i in 1..10 {
         info!("Sending message");
-        tx.send(Message::Text(format!("{}", i))).await.expect("Failed to send message");
+        tx.send(Message::text(format!("{}", i))).await.expect("Failed to send message");
     }
 
     tx.close().await.expect("Failed to close");