-
Notifications
You must be signed in to change notification settings - Fork 73
/
aborting-spec.ts
30 lines (28 loc) · 1.08 KB
/
aborting-spec.ts
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
import '../asynciterablehelpers.js';
import { jest } from '@jest/globals';
import { interval } from 'ix/asynciterable/index.js';
import { take } from 'ix/asynciterable/operators/index.js';
test("Abort signal isn't overloaded with event listeners", async () => {
const abortController = new AbortController();
const listeners: (() => void)[] = [];
// eslint-disable-next-line jest/no-jasmine-globals
jest
.spyOn(abortController.signal, 'addEventListener')
.mockImplementation((_, listener) => listeners.push(listener as any));
// eslint-disable-next-line jest/no-jasmine-globals
jest
.spyOn(abortController.signal, 'removeEventListener')
.mockImplementation((_, listener) => listeners.splice(listeners.indexOf(listener as any), 1));
await interval(10)
.pipe(take(10))
.forEach(
() => {
return;
},
null,
abortController.signal
);
expect(abortController.signal.addEventListener).toHaveBeenCalledTimes(10);
expect(abortController.signal.removeEventListener).toHaveBeenCalledTimes(10);
expect(listeners).toHaveLength(0);
});