-
Notifications
You must be signed in to change notification settings - Fork 0
/
index.js
62 lines (62 loc) · 1.87 KB
/
index.js
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
"use strict";
var _a;
Object.defineProperty(exports, "__esModule", { value: true });
exports.AggregatedAbortController = void 0;
const AggregatedAbortControllerSymbol = Symbol('AggregatedAbortController');
class AggregatedAbortController extends AbortController {
constructor(items) {
super();
this[_a] = {
signals: new Set(),
registers: new WeakMap()
};
for (const item of items) {
const signal = item instanceof AbortController
? item.signal
: item instanceof AbortSignal
? item
: undefined;
if (signal !== undefined)
this.attach(signal);
}
}
/**
* Attach a signal to this controller.
*/
attach(signal) {
const { signals, registers } = this[AggregatedAbortControllerSymbol];
if (registers.has(signal)) {
return false;
}
const handler = () => this.abort();
signals.add(signal);
registers.set(signal, handler);
signal.addEventListener('abort', handler);
return true;
}
/**
* Detach a signal from this controller.
*/
detach(signal) {
const { signals, registers } = this[AggregatedAbortControllerSymbol];
const handler = registers.get(signal);
if (handler === undefined) {
return false;
}
signal.removeEventListener('abort', handler);
signals.delete(signal);
registers.delete(signal);
return true;
}
/**
* Detach all signals from this controller.
*/
detachAll() {
const { signals } = this[AggregatedAbortControllerSymbol];
for (const signal of signals) {
this.detach(signal);
}
}
}
exports.AggregatedAbortController = AggregatedAbortController;
_a = AggregatedAbortControllerSymbol;