use named parameter for abort controller in sync stream

Author: stevensJourney

packages/powersync/lib/src/database/native/native_powersync_database.dart

@@ -332,7 +332,7 @@ Future<void> _powerSyncDatabaseIsolate(
         updateStream: updateController.stream,
         retryDelay: args.retryDelay,
         client: http.Client());
-    sync.streamingSync(null);
+    sync.streamingSync();
     sync.statusStream.listen((event) {
       sPort.send(['status', event]);
     });

packages/powersync/lib/src/database/web/web_powersync_database.dart

@@ -144,7 +144,7 @@ class PowerSyncDatabaseImpl
     sync.statusStream.listen((event) {
       setStatus(event);
     });
-    sync.streamingSync(disconnecter);
+    sync.streamingSync(abortController: disconnecter);
   }
 
   /// Takes a read lock, without starting a transaction.

packages/powersync/lib/src/streaming_sync.dart

@@ -49,7 +49,7 @@ class StreamingSyncImplementation {
     statusStream = _statusStreamController.stream;
   }
 
-  Future<void> streamingSync(AbortController? abortController) async {
+  Future<void> streamingSync({AbortController? abortController}) async {
     crudLoop();
     var invalidCredentials = false;
     while (true) {
@@ -65,7 +65,7 @@ class StreamingSyncImplementation {
           await invalidCredentialsCallback!();
           invalidCredentials = false;
         }
-        await streamingSyncIteration(abortController);
+        await streamingSyncIteration(abortController: abortController);
         // Continue immediately
       } catch (e, stacktrace) {
         final message = _syncErrorMessage(e);
@@ -178,7 +178,8 @@ class StreamingSyncImplementation {
     _statusStreamController.add(newStatus);
   }
 
-  Future<bool> streamingSyncIteration(AbortController? abortController) async {
+  Future<bool> streamingSyncIteration(
+      {AbortController? abortController}) async {
     adapter.startSession();
     final bucketEntries = await adapter.getBucketStates();