fix(graphql): add query timeout argument when create client.

zino-hofmann · Jul 19, 2024 · 195326f · 195326f
1 parent 0b1b327
commit 195326f
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/packages/graphql/lib/src/core/query_manager.dart b/packages/graphql/lib/src/core/query_manager.dart
@@ -27,6 +27,7 @@ class QueryManager {
     required this.link,
     required this.cache,
     this.alwaysRebroadcast = false,
+    this.requestTimeout = const Duration(seconds: 5),
   }) {
     scheduler = QueryScheduler(
       queryManager: this,
@@ -39,6 +40,9 @@ class QueryManager {
   /// Whether to skip deep equality checks in [maybeRebroadcastQueries]
   final bool alwaysRebroadcast;
 
+  /// The timeout for resolving a query
+  final Duration requestTimeout;
+
   QueryScheduler? scheduler;
   static final _oneOffOpId = '0';
   int idCounter = 1;
@@ -244,8 +248,7 @@ class QueryManager {
 
     try {
       // execute the request through the provided link(s)
-      response =
-          await link.request(request).timeout(Duration(seconds: 5)).first;
+      response = await link.request(request).timeout(this.requestTimeout).first;
 
       queryResult = mapFetchResultToQueryResult(
         response,

diff --git a/packages/graphql/lib/src/graphql_client.dart b/packages/graphql/lib/src/graphql_client.dart
@@ -26,11 +26,13 @@ class GraphQLClient implements GraphQLDataProxy {
     required this.cache,
     DefaultPolicies? defaultPolicies,
     bool alwaysRebroadcast = false,
+    Duration queryRequestTimeout = const Duration(seconds: 5),
   })  : defaultPolicies = defaultPolicies ?? DefaultPolicies(),
         queryManager = QueryManager(
           link: link,
           cache: cache,
           alwaysRebroadcast: alwaysRebroadcast,
+          requestTimeout: queryRequestTimeout,
         );
 
   /// The default [Policies] to set for each client action