Fix subscription

Signed-off-by: Joe Grund <[email protected]>

Author: Joe Grund

juniper_axum/src/subscriptions.rs

@@ -488,7 +488,7 @@ where
             Ok(match output {
                 graphql_transport_ws::Output::Message(msg) => {
                     serde_json::to_string(&msg)
-                        .map(ws::Message::Text)
+                        .map(ws::Message::text)
                         .unwrap_or_else(|e| {
                             ws::Message::Close(Some(ws::CloseFrame {
                                 code: 1011, // CloseCode::Error
@@ -618,7 +618,7 @@ where
     let output = s_rx
         .map(|msg| {
             Ok(serde_json::to_string(&msg)
-                .map(ws::Message::Text)
+                .map(ws::Message::text)
                 .unwrap_or_else(|e| {
                     ws::Message::Close(Some(ws::CloseFrame {
                         code: 1011, // CloseCode::Error

juniper_axum/tests/ws_test_suite.rs

@@ -88,7 +88,7 @@ impl TestApp {
                     None => Err(anyhow!("No message received")),
                     Some(Err(e)) => Err(anyhow!("WebSocket error: {e}")),
                     Some(Ok(Message::Text(json))) => {
-                        let actual: serde_json::Value = serde_json::from_str(&*json)
+                        let actual: serde_json::Value = serde_json::from_str(&json)
                             .map_err(|e| anyhow!("Cannot deserialize received message: {e}"))?;
                         if actual != expected {
                             return Err(anyhow!(