From 838cbe3cd0fcca31dc05a9b0defd2f2e3ddbbdb1 Mon Sep 17 00:00:00 2001 From: Joe Grund Date: Wed, 1 Jan 2025 12:33:58 -0500 Subject: [PATCH] Fix subscription Signed-off-by: Joe Grund --- juniper_axum/src/subscriptions.rs | 4 ++-- juniper_axum/tests/ws_test_suite.rs | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/juniper_axum/src/subscriptions.rs b/juniper_axum/src/subscriptions.rs index cc1ec7d70..9ca12b8bd 100644 --- a/juniper_axum/src/subscriptions.rs +++ b/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 diff --git a/juniper_axum/tests/ws_test_suite.rs b/juniper_axum/tests/ws_test_suite.rs index f60f671e1..92d7de1ca 100644 --- a/juniper_axum/tests/ws_test_suite.rs +++ b/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!(