fix(fl_query): use sync connection checker instead of async in every operation

.dart_tool/package_config.json

@@ -242,7 +242,7 @@
       "languageVersion": "2.17"
     }
   ],
-  "generated": "2023-05-29T02:30:48.970388Z",
+  "generated": "2023-10-07T04:33:29.262541Z",
   "generator": "pub",
-  "generatorVersion": "3.0.2"
+  "generatorVersion": "3.1.0"
 }

.dart_tool/version

@@ -1 +1 @@
-3.10.2
+3.13.2

packages/fl_query/lib/src/core/infinite_query.dart

@@ -278,7 +278,7 @@ class InfiniteQuery<DataType, ErrorType, PageType>
   bool get hasNextPage => getNextPage != null;
 
   Future<void> _operate(PageType page) async {
-    if (!await QueryClient.connectivity.isConnected &&
+    if (!QueryClient.connectivity.isConnectedSync &&
         retryConfig.cancelWhenOffline) {
       return;
     }

packages/fl_query/lib/src/core/mixins/retryer.dart

@@ -2,6 +2,7 @@ import 'dart:async';
 
 import 'package:async/async.dart';
 import 'package:fl_query/src/collections/retry_config.dart';
+import 'package:fl_query/src/core/client.dart';
 import 'package:flutter/material.dart';
 
 mixin Retryer<T, E> {
@@ -36,6 +37,9 @@ mixin Retryer<T, E> {
             ),
           );
         }
+        if (!await QueryClient.connectivity.isConnected) {
+          break;
+        }
       }
     }
   }

packages/fl_query/lib/src/core/mutation.dart

@@ -96,7 +96,7 @@ class Mutation<DataType, ErrorType, VariablesType>
   Stream<VariablesType> get mutationStream => _mutationController.stream;
 
   Future<void> _operate(VariablesType variables) async {
-    if (!await QueryClient.connectivity.isConnected &&
+    if (!QueryClient.connectivity.isConnectedSync &&
         retryConfig.cancelWhenOffline) {
       return;
     }

packages/fl_query/lib/src/core/query.dart

@@ -147,7 +147,7 @@ class Query<DataType, ErrorType>
   CancelableOperation<void>? _operation;
 
   Future<void> _operate() async {
-    if (!await QueryClient.connectivity.isConnected &&
+    if (!QueryClient.connectivity.isConnectedSync &&
         retryConfig.cancelWhenOffline) {
       return;
     }