code cleanup

Author: stevensJourney

packages/powersync/lib/src/streaming_sync.dart

@@ -158,9 +158,6 @@ class StreamingSyncImplementation {
         }
       }
     } finally {
-      // The client should no longer be connected at this point
-      // Adding this update allows for breaking out of an in-progress updateLoop
-      _updateStatus(connected: false);
       _abort!.completeAbort();
     }
   }
@@ -493,7 +490,7 @@ class StreamingSyncImplementation {
     }
   }
 
-  /// Delays the standard `retryDelay` Duration, but exists early if
+  /// Delays the standard `retryDelay` Duration, but exits early if
   /// an abort has been requested.
   Future<void> _delayRetry() async {
     await Future.any([Future.delayed(retryDelay), _abort!.onAbort]);

packages/powersync/test/connected_test.dart

@@ -21,7 +21,7 @@ void main() {
     });
 
     tearDown(() async {
-      // await testUtils.cleanDb(path: path);
+      await testUtils.cleanDb(path: path);
     });
 
     createTestServer() async {

packages/powersync/test/server/sync_server/mock_sync_server.dart

@@ -21,10 +21,9 @@ class TestHttpServerHelper {
         // Respond immediately with a stream
         return Response.ok(_controller.stream.transform(utf8.encoder),
             headers: {
-              'Content-Type': 'text/event-stream',
+              'Content-Type': 'application/x-ndjson',
               'Cache-Control': 'no-cache',
               'Connection': 'keep-alive',
-              'Transfer-Encoding': 'identity',
             },
             context: {
               "shelf.io.buffer_output": false