1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
import { it, expect } from "bun:test";
import { bunExe, bunEnv } from "harness";
import path from "path";
it("setImmediate", async () => {
var lastID = -1;
const result = await new Promise((resolve, reject) => {
var numbers = [];
for (let i = 0; i < 10; i++) {
const id = setImmediate((...args) => {
numbers.push(i);
if (i === 9) {
resolve(numbers);
}
try {
expect(args.length).toBe(1);
expect(args[0]).toBe(i);
} catch (err) {
reject(err);
}
}, i);
expect(id > lastID).toBe(true);
lastID = id;
}
});
for (let j = 0; j < result.length; j++) {
expect(result[j]).toBe(j);
}
expect(result.length).toBe(10);
});
it("clearImmediate", async () => {
var called = false;
const id = setImmediate(() => {
called = true;
expect(false).toBe(true);
});
clearImmediate(id);
// assert it doesn't crash if you call clearImmediate twice
clearImmediate(id);
await new Promise((resolve, reject) => {
setImmediate(resolve);
});
expect(called).toBe(false);
});
it("setImmediate should not keep the process alive forever", async () => {
let process = null;
const success = async () => {
process = Bun.spawn({
cmd: [bunExe(), "run", path.join(import.meta.dir, "process-setImmediate-fixture.js")],
stdout: "ignore",
env: {
...bunEnv,
NODE_ENV: undefined,
},
});
await process.exited;
process = null;
return true;
};
const fail = async () => {
await Bun.sleep(500);
process?.kill();
return false;
};
expect(await Promise.race([success(), fail()])).toBe(true);
});
|
