Skip to content

Commit 8baad1c

Browse files
committed
Add missing members to throttled database
1 parent 090e6c8 commit 8baad1c

File tree

2 files changed

+13
-2
lines changed

2 files changed

+13
-2
lines changed

packages/sqlite_async/lib/src/web/worker/throttled_common_database.dart

+12-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import 'dart:async';
22

3-
import 'package:sqlite_async/sqlite3_common.dart';
3+
import 'package:sqlite_async/sqlite3_wasm.dart';
44

55
/// Wrap a CommonDatabase to throttle its updates stream.
66
/// This is so that we can throttle the updates _within_
@@ -103,6 +103,17 @@ class ThrottledCommonDatabase extends CommonDatabase {
103103
Stream<SqliteUpdate> get updates {
104104
return throttledUpdates(_db, _transactionController.stream);
105105
}
106+
107+
@override
108+
VoidPredicate? get commitFilter => _db.commitFilter;
109+
110+
set commitFilter(VoidPredicate? filter) => _db.commitFilter = filter;
111+
112+
@override
113+
Stream<void> get commits => _db.commits;
114+
115+
@override
116+
Stream<void> get rollbacks => _db.rollbacks;
106117
}
107118

108119
/// This throttles the database update stream to:

packages/sqlite_async/pubspec.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ topics:
1212
- flutter
1313

1414
dependencies:
15-
sqlite3: ^2.6.0
15+
sqlite3: ^2.7.0
1616
sqlite3_web: ^0.2.1
1717
async: ^2.10.0
1818
collection: ^1.17.0

0 commit comments

Comments
 (0)