Merge pull request #83 from negezor/update-poem-redis-subscription-redis

Replace deprecated redis calls in poem subscription example

Author: sunli829

poem/subscription-redis/Cargo.toml

@@ -8,5 +8,5 @@ async-graphql = { path = "../../.." }
 async-graphql-poem = { path = "../../../integrations/poem" }
 tokio = { version = "1.8", features = ["macros", "rt-multi-thread"] }
 poem = { version = "3.0.0", features = ["websocket"] }
-redis = { version = "0.21.4", features = ["aio", "tokio-comp"] }
+redis = { version = "0.25.2", features = ["aio", "tokio-comp"] }
 futures-util = "0.3.19"

poem/subscription-redis/src/main.rs

@@ -19,7 +19,7 @@ struct MutationRoot;
 impl MutationRoot {
     async fn publish(&self, ctx: &Context<'_>, value: String) -> Result<bool> {
         let client = ctx.data_unchecked::<Client>();
-        let mut conn = client.get_async_connection().await?;
+        let mut conn = client.get_multiplexed_async_connection().await?;
         conn.publish("values", value).await?;
         Ok(true)
     }
@@ -31,7 +31,7 @@ struct SubscriptionRoot;
 impl SubscriptionRoot {
     async fn values(&self, ctx: &Context<'_>) -> Result<impl Stream<Item = String>> {
         let client = ctx.data_unchecked::<Client>();
-        let mut conn = client.get_async_connection().await?.into_pubsub();
+        let mut conn = client.get_async_pubsub().await?;
         conn.subscribe("values").await?;
         Ok(conn
             .into_on_message()