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 {
239
239
await tx.execute ('DELETE FROM ${quoteIdentifier (row ['name' ])}' );
240
240
}
241
241
});
242
+ // The data has been deleted - reset these
243
+ setStatus (SyncStatus (lastSyncedAt: null , hasSynced: false ));
242
244
}
243
245
244
246
@Deprecated ('Use [disconnectAndClear] instead.' )
Original file line number Diff line number Diff line change 1
1
import 'dart:async' ;
2
2
import 'dart:convert' as convert;
3
+
3
4
import 'package:http/http.dart' as http;
4
5
import 'package:powersync/src/abort_controller.dart' ;
5
6
import 'package:powersync/src/exceptions.dart' ;
@@ -143,6 +144,9 @@ class StreamingSyncImplementation {
143
144
await uploadAllCrud ();
144
145
145
146
await for (var _ in updateStream) {
147
+ if (_abort? .aborted == true ) {
148
+ break ;
149
+ }
146
150
await uploadAllCrud ();
147
151
}
148
152
}
You can’t perform that action at this time.
0 commit comments