Skip to content

Commit

Permalink
fix onSync
Browse files Browse the repository at this point in the history
  • Loading branch information
alextekartik committed Feb 3, 2024
1 parent fac527a commit 2668588
Showing 1 changed file with 11 additions and 0 deletions.
11 changes: 11 additions & 0 deletions app_cv_sembast/test/app_cv_sembast_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -199,13 +199,21 @@ void main() {
var cvRecordRef = cvStore.record(1); //
await (cvRecordRef.cv()..value.v = 2).put(db);
DbTest? record;
var completer = Completer<void>();
var subscription = cvRecordRef.onRecordSync(db).listen((event) {
record = event;
if (event?.value.v == 3) {
completer.complete();
}
});
var firstCompleter = Completer<void>();
scheduleMicrotask(() {
expect(record?.value.v, 2);
firstCompleter.complete();
});
await firstCompleter.future;
await (cvRecordRef.cv()..value.v = 3).put(db);
await completer.future;
expect(record?.value.v, 3);

await subscription.cancel();
Expand Down Expand Up @@ -241,9 +249,12 @@ void main() {
completer.complete();
}
});
var firstCompleter = Completer<void>();
scheduleMicrotask(() {
expect(records, hasLength(1));
firstCompleter.complete();
});
await firstCompleter.future;
await cvRecordRef2.put(db, cvRecordRef.cv()..value.v = 2);
await completer.future;
expect(records, hasLength(2));
Expand Down

0 comments on commit 2668588

Please sign in to comment.