File tree Expand file tree Collapse file tree 2 files changed +6
-0
lines changed
packages/powersync/lib/src Expand file tree Collapse file tree 2 files changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -239,6 +239,8 @@ mixin PowerSyncDatabaseMixin implements SqliteConnection {
239239 await tx.execute ('DELETE FROM ${quoteIdentifier (row ['name' ])}' );
240240 }
241241 });
242+ // The data has been deleted - reset these
243+ setStatus (SyncStatus (lastSyncedAt: null , hasSynced: false ));
242244 }
243245
244246 @Deprecated ('Use [disconnectAndClear] instead.' )
Original file line number Diff line number Diff line change 11import 'dart:async' ;
22import 'dart:convert' as convert;
3+
34import 'package:http/http.dart' as http;
45import 'package:powersync/src/abort_controller.dart' ;
56import 'package:powersync/src/exceptions.dart' ;
@@ -143,6 +144,9 @@ class StreamingSyncImplementation {
143144 await uploadAllCrud ();
144145
145146 await for (var _ in updateStream) {
147+ if (_abort? .aborted == true ) {
148+ break ;
149+ }
146150 await uploadAllCrud ();
147151 }
148152 }
You can’t perform that action at this time.
0 commit comments