Unverified Commit 568b0ac5 authored by Hong Minhee's avatar Hong Minhee
Browse files

Let RedisMessageQueue.listen() take an AbortSignal

parent b4ffc227

README.md

+2 −0
Original line number Diff line number Diff line
@@ -66,6 +66,8 @@ Changelog 


To be released.



 -  Let `RedisMessageQueue` follow up the latest `MessageQueue` interface,

    which was updated in Fedify 1.0.0.

 -  Added some example code.



### Version 0.1.1

deno.json

+2 −2
Original line number Diff line number Diff line
@@ -9,8 +9,8 @@ 
    "./mq": "./src/mq.ts"

  },

  "imports": {

    "@deno/dnt": "jsr:@deno/dnt@^0.41.2",

    "@fedify/fedify": "jsr:@fedify/fedify@^0.10.0",

    "@deno/dnt": "jsr:@deno/dnt@^0.41.3",

    "@fedify/fedify": "jsr:@fedify/fedify@^1.0.0-dev.409+33f0f302",

    "@std/assert": "jsr:@std/assert@^0.226.0",

    "@std/async": "jsr:@std/async@^0.224.2",

    "ioredis": "npm:ioredis@^5.4.0"

deno.lock

+120 −197

File changed.

Preview size limit exceeded, changes collapsed.

dnt.ts

+2 −1
Original line number Diff line number Diff line
@@ -10,7 +10,8 @@ await Deno.writeTextFile( 
    imports: {

      ...metadata.imports,

      "@fedify/fedify": metadata.imports["@fedify/fedify"]

        .replace(/^jsr:/, "npm:"),

        .replace(/^jsr:/, "npm:")

        .replace(/\+.+$/, ""),

    },

  }),

);

src/mq.test.ts

+9 −4
Original line number Diff line number Diff line
@@ -21,12 +21,13 @@ Deno.test("RedisMessageQueue", async (t) => { 
  });



  const messages: string[] = [];

  mq.listen((message: string) => {

  const controller = new AbortController();

  const listening = mq.listen((message: string) => {

    messages.push(message);

  });

  mq2.listen((message: string) => {

  }, controller);

  const listening2 = mq2.listen((message: string) => {

    messages.push(message);

  });

  }, controller);



  await t.step("enqueue()", async () => {

    await mq.enqueue("Hello, world!");
@@ -54,6 +55,10 @@ Deno.test("RedisMessageQueue", async (t) => { 
    assertGreater(Date.now() - started, 3_000);

  });



  controller.abort();

  await listening;

  await listening2;



  mq[Symbol.dispose]();

  mq2[Symbol.dispose]();

});