fix(ext/kv): throw error if already closed (#21459)

If KV is closed and tries to listen queue should throw an error

closes #20991

2 files changed, 14 insertions, 0 deletions

diff --git a/cli/tests/integration/js_unit_tests.rs b/cli/tests/integration/js_unit_tests.rs
index d4a56b63e..bdab48926 100644
--- a/cli/tests/integration/js_unit_tests.rs
+++ b/cli/tests/integration/js_unit_tests.rs
@@ -48,6 +48,7 @@ util::unit_test_factory!(
     jupyter_test,
     kv_test,
     kv_queue_test_no_db_close,
+    kv_queue_test,
     kv_queue_undelivered_test,
     link_test,
     make_temp_test,
diff --git a/cli/tests/unit/kv_queue_test.ts b/cli/tests/unit/kv_queue_test.ts
new file mode 100644
index 000000000..86b9d21a8
--- /dev/null
+++ b/cli/tests/unit/kv_queue_test.ts
@@ -0,0 +1,13 @@
+// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
+import { assertEquals, assertFalse } from "./test_util.ts";
+
+Deno.test({}, async function queueTestDbClose() {
+  const db: Deno.Kv = await Deno.openKv(":memory:");
+  db.close();
+  try {
+    await db.listenQueue(() => {});
+    assertFalse(false);
+  } catch (e) {
+    assertEquals(e.message, "already closed");
+  }
+});