update examples

Author: sunli829

federation/dynamic-schema/federation-accounts/src/main.rs

@@ -90,7 +90,10 @@ fn schema() -> Result<Schema, SchemaError> {
             |ctx| {
                 FieldFuture::new(async move {
                     let user = ctx.parent_value.try_downcast_ref::<User>()?;
-                    Ok(user.profile_picture.as_ref().map(FieldValue::borrowed_any))
+                    Ok(user
+                        .profile_picture
+                        .as_ref()
+                        .map(|pic| FieldValue::borrowed_any(pic)))
                 })
             },
         ))

federation/dynamic-schema/federation-reviews/src/main.rs

@@ -141,7 +141,10 @@ fn schema() -> Result<Schema, SchemaError> {
                 FieldFuture::new(async move {
                     let review = ctx.parent_value.try_downcast_ref::<Review>()?;
                     Ok(Some(FieldValue::list(
-                        review.pictures.iter().map(FieldValue::borrowed_any),
+                        review
+                            .pictures
+                            .iter()
+                            .map(|review| FieldValue::borrowed_any(review)),
                     )))
                 })
             },
@@ -198,7 +201,9 @@ fn schema() -> Result<Schema, SchemaError> {
                 FieldFuture::new(async move {
                     let reviews = ctx.data::<Vec<Review>>()?;
                     Ok(Some(FieldValue::list(
-                        reviews.iter().map(FieldValue::borrowed_any),
+                        reviews
+                            .iter()
+                            .map(|review| FieldValue::borrowed_any(review)),
                     )))
                 })
             },
@@ -253,7 +258,7 @@ fn schema() -> Result<Schema, SchemaError> {
                         reviews
                             .iter()
                             .filter(|review| review.get_author().id == user.id)
-                            .map(FieldValue::borrowed_any),
+                            .map(|review| FieldValue::borrowed_any(review)),
                     )))
                 })
             },

models/dynamic-starwars/src/model.rs

@@ -214,7 +214,9 @@ pub fn schema() -> Result<Schema, SchemaError> {
                 FieldFuture::new(async move {
                     let starwars = ctx.data::<StarWars>()?;
                     let id = ctx.args.try_get("id")?;
-                    Ok(starwars.human(id.string()?).map(FieldValue::borrowed_any))
+                    Ok(starwars
+                        .human(id.string()?)
+                        .map(|human| FieldValue::borrowed_any(human)))
                 })
             })
             .argument(InputValue::new("id", TypeRef::named_nn(TypeRef::STRING))),
@@ -227,7 +229,9 @@ pub fn schema() -> Result<Schema, SchemaError> {
                     let starwars = ctx.data::<StarWars>()?;
                     let humans = starwars.humans();
                     Ok(Some(FieldValue::list(
-                        humans.into_iter().map(FieldValue::borrowed_any),
+                        humans
+                            .into_iter()
+                            .map(|human| FieldValue::borrowed_any(human)),
                     )))
                 })
             },
@@ -237,7 +241,9 @@ pub fn schema() -> Result<Schema, SchemaError> {
                 FieldFuture::new(async move {
                     let starwars = ctx.data::<StarWars>()?;
                     let id = ctx.args.try_get("id")?;
-                    Ok(starwars.droid(id.string()?).map(FieldValue::borrowed_any))
+                    Ok(starwars
+                        .droid(id.string()?)
+                        .map(|droid| FieldValue::borrowed_any(droid)))
                 })
             })
             .argument(InputValue::new("id", TypeRef::named_nn(TypeRef::STRING))),
@@ -250,7 +256,9 @@ pub fn schema() -> Result<Schema, SchemaError> {
                     let starwars = ctx.data::<StarWars>()?;
                     let droids = starwars.droids();
                     Ok(Some(FieldValue::list(
-                        droids.into_iter().map(FieldValue::borrowed_any),
+                        droids
+                            .into_iter()
+                            .map(|droid| FieldValue::borrowed_any(droid)),
                     )))
                 })
             },

poem/subscription-redis/Cargo.toml

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

poem/subscription-redis/src/main.rs

@@ -20,7 +20,7 @@ impl MutationRoot {
     async fn publish(&self, ctx: &Context<'_>, value: String) -> Result<bool> {
         let client = ctx.data_unchecked::<Client>();
         let mut conn = client.get_multiplexed_async_connection().await?;
-        conn.publish("values", value).await?;
+        conn.publish::<_, _, ()>("values", value).await?;
         Ok(true)
     }
 }