From 3d1d1290fc80d4abda3840b98f9f6c7eb1e043f6 Mon Sep 17 00:00:00 2001
From: Sunli <scott_s829@163.com>
Date: Mon, 15 Aug 2022 12:10:03 +0800
Subject: [PATCH] `on_connection_init` takes `FnOnce` instead of `Fn`  #1022

---
 integrations/actix-web/src/subscription.rs | 4 ++--
 integrations/axum/src/subscription.rs      | 4 ++--
 integrations/poem/src/subscription.rs      | 4 ++--
 integrations/warp/src/subscription.rs      | 4 ++--
 4 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/integrations/actix-web/src/subscription.rs b/integrations/actix-web/src/subscription.rs
index bc419374..5a42fb3c 100644
--- a/integrations/actix-web/src/subscription.rs
+++ b/integrations/actix-web/src/subscription.rs
@@ -60,7 +60,7 @@ where
     Query: ObjectType + 'static,
     Mutation: ObjectType + 'static,
     Subscription: SubscriptionType + 'static,
-    OnInit: Fn(serde_json::Value) -> OnInitFut + Unpin + Send + 'static,
+    OnInit: FnOnce(serde_json::Value) -> OnInitFut + Unpin + Send + 'static,
     OnInitFut: Future<Output = async_graphql::Result<Data>> + Send + 'static,
 {
     /// Specify the initial subscription context data, usually you can get
@@ -81,7 +81,7 @@ where
         callback: OnConnInit2,
     ) -> GraphQLSubscription<Query, Mutation, Subscription, OnConnInit2>
     where
-        OnConnInit2: Fn(serde_json::Value) -> Fut + Unpin + Send + 'static,
+        OnConnInit2: FnOnce(serde_json::Value) -> Fut + Unpin + Send + 'static,
         Fut: Future<Output = async_graphql::Result<Data>> + Send + 'static,
     {
         GraphQLSubscription {
diff --git a/integrations/axum/src/subscription.rs b/integrations/axum/src/subscription.rs
index 0bf42338..0f554f1c 100644
--- a/integrations/axum/src/subscription.rs
+++ b/integrations/axum/src/subscription.rs
@@ -194,7 +194,7 @@ where
     Query: ObjectType + 'static,
     Mutation: ObjectType + 'static,
     Subscription: SubscriptionType + 'static,
-    OnConnInit: Fn(serde_json::Value) -> OnConnInitFut + Send + Sync + 'static,
+    OnConnInit: FnOnce(serde_json::Value) -> OnConnInitFut + Send + 'static,
     OnConnInitFut: Future<Output = async_graphql::Result<Data>> + Send + 'static,
 {
     /// Specify the initial subscription context data, usually you can get
@@ -215,7 +215,7 @@ where
         callback: OnConnInit2,
     ) -> GraphQLWebSocket<Sink, Stream, Query, Mutation, Subscription, OnConnInit2>
     where
-        OnConnInit2: Fn(serde_json::Value) -> Fut + Send + Sync + 'static,
+        OnConnInit2: FnOnce(serde_json::Value) -> Fut + Send + 'static,
         Fut: Future<Output = async_graphql::Result<Data>> + Send + 'static,
     {
         GraphQLWebSocket {
diff --git a/integrations/poem/src/subscription.rs b/integrations/poem/src/subscription.rs
index be87f65f..55bf0b24 100644
--- a/integrations/poem/src/subscription.rs
+++ b/integrations/poem/src/subscription.rs
@@ -182,7 +182,7 @@ where
     Query: ObjectType + 'static,
     Mutation: ObjectType + 'static,
     Subscription: SubscriptionType + 'static,
-    OnConnInit: Fn(serde_json::Value) -> OnConnInitFut + Send + Sync + 'static,
+    OnConnInit: FnOnce(serde_json::Value) -> OnConnInitFut + Send + 'static,
     OnConnInitFut: Future<Output = async_graphql::Result<Data>> + Send + 'static,
 {
     /// Specify the initial subscription context data, usually you can get
@@ -203,7 +203,7 @@ where
         callback: OnConnInit2,
     ) -> GraphQLWebSocket<Sink, Stream, Query, Mutation, Subscription, OnConnInit2>
     where
-        OnConnInit2: Fn(serde_json::Value) -> Fut + Send + Sync + 'static,
+        OnConnInit2: FnOnce(serde_json::Value) -> Fut + Send + 'static,
         Fut: Future<Output = async_graphql::Result<Data>> + Send + 'static,
     {
         GraphQLWebSocket {
diff --git a/integrations/warp/src/subscription.rs b/integrations/warp/src/subscription.rs
index a25b4631..dcbd6165 100644
--- a/integrations/warp/src/subscription.rs
+++ b/integrations/warp/src/subscription.rs
@@ -232,7 +232,7 @@ where
     Query: ObjectType + 'static,
     Mutation: ObjectType + 'static,
     Subscription: SubscriptionType + 'static,
-    OnConnInit: Fn(serde_json::Value) -> OnConnInitFut + Send + Sync + 'static,
+    OnConnInit: FnOnce(serde_json::Value) -> OnConnInitFut + Send + 'static,
     OnConnInitFut: Future<Output = async_graphql::Result<Data>> + Send + 'static,
 {
     /// Specify the initial subscription context data, usually you can get
@@ -253,7 +253,7 @@ where
         callback: OnConnInit2,
     ) -> GraphQLWebSocket<Sink, Stream, Query, Mutation, Subscription, OnConnInit2>
     where
-        OnConnInit2: Fn(serde_json::Value) -> Fut + Send + Sync + 'static,
+        OnConnInit2: FnOnce(serde_json::Value) -> Fut + Send + 'static,
         Fut: Future<Output = async_graphql::Result<Data>> + Send + 'static,
     {
         GraphQLWebSocket {