Commit b0be7f43 authored by ooheunda's avatar ooheunda
Browse files

fix: prevent race condition in PostgresMessageQueue test

parent afee8f65

packages/postgres/src/mq.test.ts

+1 −0
Original line number Diff line number Diff line
@@ -34,6 +34,7 @@ test("PostgresMessageQueue", { skip: dbUrl == null }, async () => { 
    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 });