Commit 2f8c4b37 authored by ooheunda's avatar ooheunda
Browse files

fix: improve PostgresMessageQueue test race condition handling

parent b0be7f43

packages/postgres/src/mq.test.ts

+1 −1
Original line number Diff line number Diff line
@@ -31,10 +31,10 @@ test("PostgresMessageQueue", { skip: dbUrl == null }, async () => { 
  try {

    const messages: string[] = [];

    const controller = new AbortController();

    await mq.initialize();

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

      messages.push(message);

    }, { signal: controller.signal });

    await delay(500); // prevent initialization race condition

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

      messages.push(message);

    }, { signal: controller.signal });