@@ -8,7 +8,6 @@ import 'package:sqlite_async/src/common/sqlite_database.dart';
88import 'package:sqlite_async/src/sqlite_connection.dart' ;
99import 'package:sqlite_async/src/sqlite_options.dart' ;
1010import 'package:sqlite_async/src/update_notification.dart' ;
11- import 'package:sqlite_async/src/web/web_mutex.dart' ;
1211import 'package:sqlite_async/src/web/web_sqlite_open_factory.dart' ;
1312import 'package:sqlite_async/web.dart' ;
1413
@@ -43,7 +42,6 @@ class SqliteDatabaseImpl
4342 @override
4443 AbstractDefaultSqliteOpenFactory openFactory;
4544
46- late final Mutex mutex;
4745 late final WebDatabase _connection;
4846 StreamSubscription ? _broadcastUpdatesSubscription;
4947
@@ -77,15 +75,15 @@ class SqliteDatabaseImpl
7775 /// 4. Creating temporary views or triggers.
7876 SqliteDatabaseImpl .withFactory (this .openFactory,
7977 {this .maxReaders = SqliteDatabase .defaultMaxReaders}) {
80- mutex = MutexImpl ();
8178 // This way the `updates` member is available synchronously
8279 updates = updatesController.stream;
8380 isInitialized = _init ();
8481 }
8582
8683 Future <void > _init () async {
87- _connection = await openFactory.openConnection (SqliteOpenOptions (
88- primaryConnection: true , readOnly: false , mutex: mutex)) as WebDatabase ;
84+ _connection = await openFactory.openConnection (
85+ SqliteOpenOptions (primaryConnection: true , readOnly: false ))
86+ as WebDatabase ;
8987
9088 final broadcastUpdates = _connection.broadcastUpdates;
9189 if (broadcastUpdates == null ) {
0 commit comments