cancel recoverySession if Supabase is disposed first?

packages/supabase_flutter/lib/src/supabase.dart

@@ -1,5 +1,6 @@
 import 'dart:async';
 
+import 'package:async/async.dart';
 import 'package:flutter/foundation.dart';
 import 'package:http/http.dart';
 import 'package:supabase/supabase.dart';
@@ -108,13 +109,17 @@ class Supabase {
 
     _instance._supabaseAuth = SupabaseAuth();
     await _instance._supabaseAuth.initialize(options: authOptions);
-    _instance._sessionRecoverCompleter
-        .complete(_instance._supabaseAuth.recoverSession());
+
+    // Wrap it in a `CancelableOperation` so that it can be canceled in dispose
+    // if still in progress
+    _instance._cancellableOperation = CancelableOperation.fromFuture(
+      _instance._supabaseAuth.recoverSession(),
+    );
 
     return _instance;
   }
 
-  Completer<void> _sessionRecoverCompleter = Completer();
+  late CancelableOperation _cancellableOperation;
 
   Supabase._();
   static final Supabase _instance = Supabase._();
@@ -132,8 +137,7 @@ class Supabase {
 
   /// Dispose the instance to free up resources.
   Future<void> dispose() async {
-    await _sessionRecoverCompleter.future;
-    _sessionRecoverCompleter = Completer();
+    await _cancellableOperation.cancel();
     client.dispose();
     _instance._supabaseAuth.dispose();
     _initialized = false;

packages/supabase_flutter/pubspec.yaml

@@ -11,6 +11,7 @@ environment:
 
 dependencies:
   app_links: ^3.4.1
+  async: ^2.11.0
   crypto: ^3.0.2
   flutter:
     sdk: flutter

packages/supabase_flutter/test/supabase_flutter_test.dart

@@ -32,7 +32,7 @@ void main() {
 
     test('can re-initialize client', () async {
       final client = Supabase.instance.client;
-      Supabase.instance.dispose();
+      await Supabase.instance.dispose();
       await Supabase.initialize(
         url: supabaseUrl,
         anonKey: supabaseKey,
@@ -61,7 +61,7 @@ void main() {
       );
     });
 
-    tearDown(() => Supabase.instance.dispose());
+    tearDown(() async => await Supabase.instance.dispose());
 
     test('initial session contains the error', () async {
       await expectLater(Supabase.instance.client.auth.onAuthStateChange,
@@ -82,7 +82,7 @@ void main() {
       );
     });
 
-    tearDown(() => Supabase.instance.dispose());
+    tearDown(() async => await Supabase.instance.dispose());
 
     test('initial session contains the error', () async {
       final event = await Supabase.instance.client.auth.onAuthStateChange.first;
@@ -111,7 +111,7 @@ void main() {
       );
     });
 
-    tearDown(() => Supabase.instance.dispose());
+    tearDown(() async => await Supabase.instance.dispose());
 
     test(
         'Having `code` as the query parameter triggers `getSessionFromUrl` call on initialize',