1 | "use strict";
|
2 |
|
3 |
|
4 |
|
5 |
|
6 |
|
7 |
|
8 |
|
9 |
|
10 |
|
11 |
|
12 |
|
13 |
|
14 |
|
15 |
|
16 |
|
17 | Object.defineProperty(exports, "__esModule", { value: true });
|
18 | exports.firstTrue = exports.isThenable = exports.waitForEvent = exports.wait = exports.delay = exports.retry = exports.timeoutReject = exports.timeout = exports.Deferred = void 0;
|
19 | const cancellation_1 = require("./cancellation");
|
20 | const types_1 = require("./types");
|
21 |
|
22 |
|
23 |
|
24 |
|
25 | class Deferred {
|
26 | constructor() {
|
27 | this.state = 'unresolved';
|
28 | this.promise = new Promise((resolve, reject) => {
|
29 | this.resolve = resolve;
|
30 | this.reject = reject;
|
31 | }).then(res => (this.setState('resolved'), res), err => (this.setState('rejected'), Promise.reject(err)));
|
32 | }
|
33 | setState(state) {
|
34 | if (this.state === 'unresolved') {
|
35 | this.state = state;
|
36 | }
|
37 | }
|
38 | }
|
39 | exports.Deferred = Deferred;
|
40 |
|
41 |
|
42 |
|
43 |
|
44 | function timeout(ms, token = cancellation_1.CancellationToken.None) {
|
45 | const deferred = new Deferred();
|
46 | const handle = setTimeout(() => deferred.resolve(), ms);
|
47 | token.onCancellationRequested(() => {
|
48 | clearTimeout(handle);
|
49 | deferred.reject((0, cancellation_1.cancelled)());
|
50 | });
|
51 | return deferred.promise;
|
52 | }
|
53 | exports.timeout = timeout;
|
54 |
|
55 |
|
56 |
|
57 |
|
58 |
|
59 |
|
60 |
|
61 |
|
62 |
|
63 |
|
64 | function timeoutReject(ms, message) {
|
65 | const deferred = new Deferred();
|
66 | setTimeout(() => deferred.reject(new Error(message)), ms);
|
67 | return deferred.promise;
|
68 | }
|
69 | exports.timeoutReject = timeoutReject;
|
70 | async function retry(task, retryDelay, retries) {
|
71 | let lastError;
|
72 | for (let i = 0; i < retries; i++) {
|
73 | try {
|
74 | return await task();
|
75 | }
|
76 | catch (error) {
|
77 | lastError = error;
|
78 | await timeout(retryDelay);
|
79 | }
|
80 | }
|
81 | throw lastError;
|
82 | }
|
83 | exports.retry = retry;
|
84 |
|
85 |
|
86 |
|
87 |
|
88 |
|
89 |
|
90 |
|
91 |
|
92 | function delay(ms) {
|
93 | return value => new Promise((resolve, reject) => { setTimeout(() => resolve(value), ms); });
|
94 | }
|
95 | exports.delay = delay;
|
96 |
|
97 |
|
98 |
|
99 |
|
100 | async function wait(ms) {
|
101 | await delay(ms)(undefined);
|
102 | }
|
103 | exports.wait = wait;
|
104 |
|
105 | function waitForEvent(event, ms, thisArg, disposables) {
|
106 | return new Promise((resolve, reject) => {
|
107 | const registration = setTimeout(() => {
|
108 | listener.dispose();
|
109 | reject(new cancellation_1.CancellationError());
|
110 | }, ms);
|
111 | const listener = event((evt) => {
|
112 | clearTimeout(registration);
|
113 | listener.dispose();
|
114 | resolve(evt);
|
115 | }, thisArg, disposables);
|
116 | });
|
117 | }
|
118 | exports.waitForEvent = waitForEvent;
|
119 | function isThenable(obj) {
|
120 | return (0, types_1.isObject)(obj) && (0, types_1.isFunction)(obj.then);
|
121 | }
|
122 | exports.isThenable = isThenable;
|
123 |
|
124 |
|
125 |
|
126 |
|
127 | function firstTrue(...promises) {
|
128 | const newPromises = promises.map(promise => new Promise((resolve, reject) => promise.then(result => result && resolve(true), reject)));
|
129 | newPromises.push(Promise.all(promises).then(() => false));
|
130 | return Promise.race(newPromises);
|
131 | }
|
132 | exports.firstTrue = firstTrue;
|
133 |
|
\ | No newline at end of file |