web: Fix crash after closing database

8456ca64 · Simon Binder · 0ea22755 · 8456ca64 · 8456ca64 · 8456ca64
--- a/sqlite3_web/CHANGELOG.md
+++ b/sqlite3_web/CHANGELOG.md
+## 0.1.1-wip
+
+- Fix remote error after closing databases.
+
+
 ## 0.1.0-wip

 - Initial WIP version.
--- a/sqlite3_web/lib/src/client.dart
+++ b/sqlite3_web/lib/src/client.dart
@@ -16,6 +16,8 @@ final class RemoteDatabase implements Database {
  final WorkerConnection connection;
  final int databaseId;

+  var _isClosed = false;
+
  StreamSubscription<Notification>? _notificationSubscription;
  final StreamController<SqliteUpdate> _updates = StreamController.broadcast();

@@ -42,15 +44,18 @@ final class RemoteDatabase implements Database {
  }

  void _requestUpdates(bool sendUpdates) {
-    connection.sendRequest(
-      UpdateStreamRequest(
-          action: sendUpdates, requestId: 0, databaseId: databaseId),
-      MessageType.simpleSuccessResponse,
-    );
+    if (!_isClosed) {
+      connection.sendRequest(
+        UpdateStreamRequest(
+            action: sendUpdates, requestId: 0, databaseId: databaseId),
+        MessageType.simpleSuccessResponse,
+      );
+    }
  }

  @override
  Future<void> dispose() async {
+    _isClosed = true;
    _updates.close();
    await connection.sendRequest(
        CloseDatabase(requestId: 0, databaseId: databaseId),

--- a/sqlite3_web/pubspec.yaml
+++ b/sqlite3_web/pubspec.yaml
 name: sqlite3_web
 description: Utilities to simplify accessing sqlite3 on the web, with automated feature detection.
-version: 0.1.0-wip
+version: 0.1.1-wip
 homepage: https://github.com/simolus3/sqlite3.dart/tree/main/sqlite3_web
 repository: https://github.com/simolus3/sqlite3.dart