1 files changed, 25 insertions, 0 deletions
diff --git a/cli/tests/unit/kv_queue_test_no_db_close.ts b/cli/tests/unit/kv_queue_test_no_db_close.ts
new file mode 100644
index 000000000..e639574a3
--- /dev/null
+++ b/cli/tests/unit/kv_queue_test_no_db_close.ts
@@ -0,0 +1,25 @@
+// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
+import {
+  assert,
+  assertEquals,
+  assertNotEquals,
+  deferred,
+} from "./test_util.ts";
+
+Deno.test({
+  sanitizeOps: false,
+  sanitizeResources: false,
+}, async function queueTestNoDbClose() {
+  const db: Deno.Kv = await Deno.openKv(":memory:");
+  const promise = deferred();
+  let dequeuedMessage: unknown = null;
+  db.listenQueue((msg) => {
+    dequeuedMessage = msg;
+    promise.resolve();
+  });
+  const res = await db.enqueue("test");
+  assert(res.ok);
+  assertNotEquals(res.versionstamp, null);
+  await promise;
+  assertEquals(dequeuedMessage, "test");
+});