mirror of
https://github.com/denoland/deno
synced 2024-09-13 21:31:18 +00:00
21 lines
644 B
TypeScript
21 lines
644 B
TypeScript
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
|
|
import { assert, assertEquals, assertNotEquals } from "./test_util.ts";
|
|
|
|
Deno.test({
|
|
sanitizeOps: false,
|
|
sanitizeResources: false,
|
|
}, async function queueTestNoDbClose() {
|
|
const db: Deno.Kv = await Deno.openKv(":memory:");
|
|
const { promise, resolve } = Promise.withResolvers<void>();
|
|
let dequeuedMessage: unknown = null;
|
|
db.listenQueue((msg) => {
|
|
dequeuedMessage = msg;
|
|
resolve();
|
|
});
|
|
const res = await db.enqueue("test");
|
|
assert(res.ok);
|
|
assertNotEquals(res.versionstamp, null);
|
|
await promise;
|
|
assertEquals(dequeuedMessage, "test");
|
|
});
|