typescriptconst kv = await Deno.openKv(":memory:");
// メッセージを追加します。
const res = await kv.enqueue({ id: 1, payload: "foo" });
assert(res.ok);
let message;
// キューを購読します
const listenPromise = kv.listenQueue((_message) => {
message = _message;
});
kv.close();
await listenPromise; // closeするとresolveされます
console.info(message);
// Output: { id: 1, payload: "foo" }