framework/concurrent/Condition.test.ts

import Condition from "@framework/concurrent/Condition";
import { beforeEach, describe, expect, it } from "vitest";

describe("Condition", () => {
    let condition: Condition;

    beforeEach(() => {
        condition = new Condition();
    });

    it("should wait until signaled", async () => {
        let isSignaled = false;

        setTimeout(() => {
            condition.signal();
            isSignaled = true;
        }, 100);

        await condition.wait();

        expect(isSignaled).toBe(true);
    });

    it("should handle multiple waiters", async () => {
        let isSignaled1 = false;
        let isSignaled2 = false;

        setTimeout(() => {
            condition.signal();
            isSignaled1 = true;
        }, 100);

        setTimeout(() => {
            condition.signal();
            isSignaled2 = true;
        }, 200);

        await Promise.all([condition.wait(), condition.wait()]);

        expect(isSignaled1).toBe(true);
        expect(isSignaled2).toBe(true);
    });
});
1	rakinar2	575	import Condition from "@framework/concurrent/Condition";
2			import { beforeEach, describe, expect, it } from "vitest";
3
4			describe("Condition", () => {
5			let condition: Condition;
6
7			beforeEach(() => {
8			condition = new Condition();
9			});
10
11			it("should wait until signaled", async () => {
12			let isSignaled = false;
13
14			setTimeout(() => {
15			condition.signal();
16			isSignaled = true;
17			}, 100);
18
19			await condition.wait();
20
21			expect(isSignaled).toBe(true);
22			});
23
24			it("should handle multiple waiters", async () => {
25			let isSignaled1 = false;
26			let isSignaled2 = false;
27
28			setTimeout(() => {
29			condition.signal();
30			isSignaled1 = true;
31			}, 100);
32
33			setTimeout(() => {
34			condition.signal();
35			isSignaled2 = true;
36			}, 200);
37
38			await Promise.all([condition.wait(), condition.wait()]);
39
40			expect(isSignaled1).toBe(true);
41			expect(isSignaled2).toBe(true);
42			});
43			});