Files
cfw-autumn/server/tests/integration/queue/start-polling-loop.test.ts

15 lines
434 B
TypeScript

import { describe, expect, test } from "bun:test";
import {
getAbortControllerCountForTesting,
startPollingLoop,
} from "@/queue/initWorkers.js";
describe("startPollingLoop", () => {
test("fails closed because Node polling was removed for Cloudflare Queues", async () => {
await expect(startPollingLoop()).rejects.toThrow(
"Node polling has been removed",
);
expect(getAbortControllerCountForTesting()).toBe(0);
});
});