File tree 2 files changed +7
-2
lines changed
2 files changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -35,6 +35,7 @@ class QueryManager {
35
35
this .alwaysRebroadcast = false ,
36
36
DeepEqualsFn ? deepEquals,
37
37
bool deduplicatePollers = false ,
38
+ this .requestTimeout = const Duration (seconds: 5 ),
38
39
}) {
39
40
scheduler = QueryScheduler (
40
41
queryManager: this ,
@@ -51,6 +52,9 @@ class QueryManager {
51
52
/// Whether to skip deep equality checks in [maybeRebroadcastQueries]
52
53
final bool alwaysRebroadcast;
53
54
55
+ /// The timeout for resolving a query
56
+ final Duration requestTimeout;
57
+
54
58
QueryScheduler ? scheduler;
55
59
static final _oneOffOpId = '0' ;
56
60
int idCounter = 1 ;
@@ -256,8 +260,7 @@ class QueryManager {
256
260
257
261
try {
258
262
// execute the request through the provided link(s)
259
- response =
260
- await link.request (request).timeout (Duration (seconds: 5 )).first;
263
+ response = await link.request (request).timeout (this .requestTimeout).first;
261
264
262
265
queryResult = mapFetchResultToQueryResult (
263
266
response,
Original file line number Diff line number Diff line change @@ -28,13 +28,15 @@ class GraphQLClient implements GraphQLDataProxy {
28
28
bool alwaysRebroadcast = false ,
29
29
DeepEqualsFn ? deepEquals,
30
30
bool deduplicatePollers = false ,
31
+ Duration queryRequestTimeout = const Duration (seconds: 5 ),
31
32
}) : defaultPolicies = defaultPolicies ?? DefaultPolicies (),
32
33
queryManager = QueryManager (
33
34
link: link,
34
35
cache: cache,
35
36
alwaysRebroadcast: alwaysRebroadcast,
36
37
deepEquals: deepEquals,
37
38
deduplicatePollers: deduplicatePollers,
39
+ requestTimeout: queryRequestTimeout,
38
40
);
39
41
40
42
/// The default [Policies] to set for each client action
You can’t perform that action at this time.
0 commit comments