diff --git a/packages/sqlite_async/lib/src/web/database/web_sqlite_database.dart b/packages/sqlite_async/lib/src/web/database/web_sqlite_database.dart index 0f38b1c..c6d1b75 100644 --- a/packages/sqlite_async/lib/src/web/database/web_sqlite_database.dart +++ b/packages/sqlite_async/lib/src/web/database/web_sqlite_database.dart @@ -8,7 +8,6 @@ import 'package:sqlite_async/src/common/sqlite_database.dart'; import 'package:sqlite_async/src/sqlite_connection.dart'; import 'package:sqlite_async/src/sqlite_options.dart'; import 'package:sqlite_async/src/update_notification.dart'; -import 'package:sqlite_async/src/web/web_mutex.dart'; import 'package:sqlite_async/src/web/web_sqlite_open_factory.dart'; import 'package:sqlite_async/web.dart'; @@ -43,7 +42,6 @@ class SqliteDatabaseImpl @override AbstractDefaultSqliteOpenFactory openFactory; - late final Mutex mutex; late final WebDatabase _connection; StreamSubscription? _broadcastUpdatesSubscription; @@ -77,15 +75,15 @@ class SqliteDatabaseImpl /// 4. Creating temporary views or triggers. SqliteDatabaseImpl.withFactory(this.openFactory, {this.maxReaders = SqliteDatabase.defaultMaxReaders}) { - mutex = MutexImpl(); // This way the `updates` member is available synchronously updates = updatesController.stream; isInitialized = _init(); } Future _init() async { - _connection = await openFactory.openConnection(SqliteOpenOptions( - primaryConnection: true, readOnly: false, mutex: mutex)) as WebDatabase; + _connection = await openFactory.openConnection( + SqliteOpenOptions(primaryConnection: true, readOnly: false)) + as WebDatabase; final broadcastUpdates = _connection.broadcastUpdates; if (broadcastUpdates == null) { diff --git a/packages/sqlite_async/test/basic_test.dart b/packages/sqlite_async/test/basic_test.dart index ed2f708..fb98e17 100644 --- a/packages/sqlite_async/test/basic_test.dart +++ b/packages/sqlite_async/test/basic_test.dart @@ -229,6 +229,10 @@ void main() { ); await completion; + }, onPlatform: { + 'browser': Skip( + 'Web locks are managed with a shared worker, which does not support timeouts', + ) }); }); }