Update to tungstenite 0.26

Author: sdroege

Cargo.lock.msrv

@@ -51,7 +51,7 @@ default-features = false
 features = ["sink"]
 
 [dependencies.tungstenite]
-version = "0.24"
+version = "0.26"
 default-features = false
 
 [dependencies.async-std]
@@ -133,7 +133,7 @@ hyper-util = { version = "0.1", features = ["tokio"] }
 http-body-util = "0.1"
 
 [dev-dependencies.tungstenite]
-version = "0.24"
+version = "0.26"
 features = ["url"]
 
 [[example]]

Cargo.toml

@@ -9,7 +9,7 @@ async fn get_case_count() -> Result<u32> {
     let msg = socket.next().await.expect("Can't fetch case count")?;
     socket.close(None).await?;
     Ok(msg
-        .into_text()?
+        .to_text()?
         .parse::<u32>()
         .expect("Can't parse case count"))
 }

examples/autobahn-client.rs

@@ -47,7 +47,7 @@ async fn handle_connection(peer: SocketAddr, stream: TcpStream) -> Result<()> {
                 };
             }
             Either::Right((_, msg_fut_continue)) => {
-                ws_sender.send(Message::Text("tick".to_owned())).await?;
+                ws_sender.send(Message::text("tick")).await?;
                 msg_fut = msg_fut_continue; // Continue receiving the WebSocket message.
                 tick_fut = interval.next(); // Wait for next tick.
             }

examples/interval-server.rs

@@ -312,11 +312,10 @@ impl<S> WebSocketStream<S> {
     }
 
     /// Close the underlying web socket
-    pub async fn close(&mut self, msg: Option<CloseFrame<'_>>) -> Result<(), WsError>
+    pub async fn close(&mut self, msg: Option<CloseFrame>) -> Result<(), WsError>
     where
         S: AsyncRead + AsyncWrite + Unpin,
     {
-        let msg = msg.map(|msg| msg.into_owned());
         self.send(Message::Close(msg)).await
     }
 }

src/lib.rs

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