stream instead of connectivity

lib/src/connectivity_stream_provider.dart

@@ -0,0 +1,7 @@
+import 'package:connectivity_plus/connectivity_plus.dart';
+import 'package:riverpod/riverpod.dart';
+
+/// A stream provider that listens to network connectivity changes.
+final connectivityStreamProvider = StreamProvider(
+  (ref) => Connectivity().onConnectivityChanged,
+);

lib/src/refresh_when_network_available_extension.dart

@@ -1,6 +1,6 @@
 import 'package:connectivity_plus/connectivity_plus.dart';
 import 'package:riverpod/riverpod.dart';
-import 'package:riverpod_community_extensions/src/connectivity_provider.dart';
+import 'package:riverpod_community_extensions/src/connectivity_stream_provider.dart';
 
 /// Adds network-aware refresh functionality to AutoDisposeRef<T> objects.
 /// This extension uses the connectivity_plus package to listen for network
@@ -35,30 +35,13 @@ extension RefreshWhenNetworkAvailableExtension<T> on AutoDisposeRef<T> {
   /// }
   /// ```
   void refreshWhenNetworkAvailable() {
-    final connectivityStream =
-        watch(connectivityProvider).onConnectivityChanged;
-
-    var isNetworkAvailable = false;
-    const validResults = [
-      ConnectivityResult.mobile,
-      ConnectivityResult.wifi,
-      ConnectivityResult.ethernet,
-      ConnectivityResult.vpn,
-      ConnectivityResult.other,
-    ];
-
-    final connectivitySubscription =
-        connectivityStream.listen((connectivityResults) {
-      final currentlyAvailable =
-          connectivityResults.any((result) => validResults.contains(result));
-      if (currentlyAvailable && !isNetworkAvailable) {
-        isNetworkAvailable = true;
-        invalidateSelf();
-      } else {
-        isNetworkAvailable = false;
-      }
+    listen(connectivityStreamProvider, (_, connectivityResults) {
+      connectivityResults.whenData((data) {
+        if (data.last != ConnectivityResult.none &&
+            data.last != ConnectivityResult.bluetooth) {
+          invalidateSelf();
+        }
+      });
     });
-
-    onDispose(connectivitySubscription.cancel);
   }
 }

test/src/refresh_when_network_available_extension_test.dart

@@ -4,7 +4,7 @@ import 'package:connectivity_plus/connectivity_plus.dart';
 import 'package:flutter_test/flutter_test.dart';
 import 'package:mocktail/mocktail.dart';
 import 'package:riverpod/riverpod.dart';
-import 'package:riverpod_community_extensions/src/connectivity_provider.dart';
+import 'package:riverpod_community_extensions/src/connectivity_stream_provider.dart';
 import 'package:riverpod_community_extensions/src/refresh_when_network_available_extension.dart';
 
 class MockConnectivity extends Mock implements Connectivity {}
@@ -13,10 +13,10 @@ void main() {
   TestWidgetsFlutterBinding.ensureInitialized();
 
   group('RefreshWhenNetworkAvailableExtension Tests', () {
-    late MockConnectivity mockConnectivity;
     late StreamController<List<ConnectivityResult>> connectivityController;
     late ProviderContainer container;
     late AutoDisposeProvider<int> myProvider;
+    late Stream<List<ConnectivityResult>> connectivityStream;
 
     var numberOfFetchDataCalls = 0;
 
@@ -27,18 +27,20 @@ void main() {
 
     setUp(() {
       numberOfFetchDataCalls = 0;
-      mockConnectivity = MockConnectivity();
       connectivityController = StreamController<List<ConnectivityResult>>();
-      when(() => mockConnectivity.onConnectivityChanged)
-          .thenAnswer((_) => connectivityController.stream);
+      connectivityStream = connectivityController.stream;
 
       myProvider = Provider.autoDispose<int>((ref) {
         ref.refreshWhenNetworkAvailable();
         return fetchData();
       });
 
       container = ProviderContainer(
-        overrides: [connectivityProvider.overrideWithValue(mockConnectivity)],
+        overrides: [
+          connectivityStreamProvider.overrideWith(
+            (ref) => connectivityStream,
+          ),
+        ],
       )..listen(myProvider, (_, __) {});
     });