Skip to content

Commit 0fd777d

Browse files
committed
test: 💍 fix flaky test
1 parent fad19f5 commit 0fd777d

1 file changed

Lines changed: 20 additions & 20 deletions

File tree

src/__tests__/concurrencyDecorator.spec.ts

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -52,18 +52,18 @@ test(`limits concurrency separately per method`, async () => {
5252
}
5353
const promises: Promise<any>[] = [];
5454
const a = new A();
55-
promises.push(a.a(3));
56-
promises.push(a.a(4));
5755
promises.push(a.a(10));
58-
promises.push(a.b(2));
59-
promises.push(a.b(3));
60-
promises.push(a.b(4));
61-
await tick(5);
62-
expect(resA).toStrictEqual([3, 4]);
63-
expect(resB).toStrictEqual([2, 3, 4]);
56+
promises.push(a.a(20));
57+
promises.push(a.a(100));
58+
promises.push(a.b(10));
59+
promises.push(a.b(20));
60+
promises.push(a.b(30));
61+
await tick(50);
62+
expect(resA).toStrictEqual([10, 20]);
63+
expect(resB).toStrictEqual([10, 20, 30]);
6464
await Promise.all(promises);
65-
expect(resA).toStrictEqual([3, 4, 10]);
66-
expect(resB).toStrictEqual([2, 3, 4]);
65+
expect(resA).toStrictEqual([10, 20, 100]);
66+
expect(resB).toStrictEqual([10, 20, 30]);
6767
});
6868

6969
test(`limits concurrency separately per instance`, async () => {
@@ -80,18 +80,18 @@ test(`limits concurrency separately per instance`, async () => {
8080
const promises: Promise<any>[] = [];
8181
const a = new A(resA);
8282
const b = new A(resB);
83-
promises.push(a.a(4));
84-
promises.push(a.a(4));
8583
promises.push(a.a(10));
86-
promises.push(b.a(3));
87-
promises.push(b.a(3));
88-
promises.push(b.a(11));
89-
await tick(5);
90-
expect(resA).toStrictEqual([4, 4]);
91-
expect(resB).toStrictEqual([3, 3]);
84+
promises.push(a.a(10));
85+
promises.push(a.a(100));
86+
promises.push(b.a(10));
87+
promises.push(b.a(10));
88+
promises.push(b.a(100));
89+
await tick(50);
90+
expect(resA).toStrictEqual([10, 10]);
91+
expect(resB).toStrictEqual([10, 10]);
9292
await Promise.all(promises);
93-
expect(resA).toStrictEqual([4, 4, 10]);
94-
expect(resB).toStrictEqual([3, 3, 11]);
93+
expect(resA).toStrictEqual([10, 10, 100]);
94+
expect(resB).toStrictEqual([10, 10, 100]);
9595
});
9696

9797
describe('limits concurrency to 1', () => {

0 commit comments

Comments
 (0)