| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 72ef41c commit f90b22d
3 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -28,12 +28,12 @@ const { | |||
| 28 | 28 | ObjectAssign, | |
| 29 | 29 | ObjectDefineProperty, | |
| 30 | 30 | ObjectPrototypeHasOwnProperty, | |
| 31 | - Promise, | ||
| 32 | 31 | } = primordials; | |
| 33 | 32 | ||
| 34 | 33 | const { | |
| 35 | 34 | promisify, | |
| 36 | 35 | convertToValidSignal, | |
| 36 | + createDeferredPromise, | ||
| 37 | 37 | getSystemErrorName | |
| 38 | 38 | } = require('internal/util'); | |
| 39 | 39 | const { isArrayBufferView } = require('internal/util/types'); | |
@@ -215,12 +215,7 @@ function exec(command, options, callback) { | |||
| 215 | 215 | ||
| 216 | 216 | const customPromiseExecFunction = (orig) => { | |
| 217 | 217 | return (...args) => { | |
| 218 | - let resolve; | ||
| 219 | - let reject; | ||
| 220 | - const promise = new Promise((res, rej) => { | ||
| 221 | - resolve = res; | ||
| 222 | - reject = rej; | ||
| 223 | - }); | ||
| 218 | + const { promise, resolve, reject } = createDeferredPromise(); | ||
| 224 | 219 | ||
| 225 | 220 | promise.child = orig(...args, (err, stdout, stderr) => { | |
| 226 | 221 | if (err !== null) { | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -3,7 +3,6 @@ | |||
| 3 | 3 | const { | |
| 4 | 4 | ArrayFrom, | |
| 5 | 5 | ObjectSetPrototypeOf, | |
| 6 | - Promise, | ||
| 7 | 6 | PromiseResolve, | |
| 8 | 7 | RegExpPrototypeTest, | |
| 9 | 8 | StringPrototypeToLowerCase, | |
@@ -31,6 +30,7 @@ const { | |||
| 31 | 30 | } = require('internal/util/types'); | |
| 32 | 31 | ||
| 33 | 32 | const { | |
| 33 | + createDeferredPromise, | ||
| 34 | 34 | customInspectSymbol: kInspect, | |
| 35 | 35 | emitExperimentalWarning, | |
| 36 | 36 | } = require('internal/util'); | |
@@ -58,15 +58,6 @@ const kLength = Symbol('kLength'); | |||
| 58 | 58 | ||
| 59 | 59 | let Buffer; | |
| 60 | 60 | ||
| 61 | - function deferred() { | ||
| 62 | - let res, rej; | ||
| 63 | - const promise = new Promise((resolve, reject) => { | ||
| 64 | - res = resolve; | ||
| 65 | - rej = reject; | ||
| 66 | - }); | ||
| 67 | - return { promise, resolve: res, reject: rej }; | ||
| 68 | - } | ||
| 69 | - | ||
| 70 | 61 | function lazyBuffer() { | |
| 71 | 62 | if (Buffer === undefined) | |
| 72 | 63 | Buffer = require('buffer').Buffer; | |
@@ -212,7 +203,7 @@ class Blob extends JSTransferable { | |||
| 212 | 203 | promise, | |
| 213 | 204 | resolve, | |
| 214 | 205 | reject | |
| 215 | - } = deferred(); | ||
| 206 | + } = createDeferredPromise(); | ||
| 216 | 207 | job.ondone = (err, ab) => { | |
| 217 | 208 | if (err !== undefined) | |
| 218 | 209 | return reject(new AbortError()); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -420,11 +420,23 @@ function sleep(msec) { | |||
| 420 | 420 | _sleep(msec); | |
| 421 | 421 | } | |
| 422 | 422 | ||
| 423 | + function createDeferredPromise() { | ||
| 424 | + let resolve; | ||
| 425 | + let reject; | ||
| 426 | + const promise = new Promise((res, rej) => { | ||
| 427 | + resolve = res; | ||
| 428 | + reject = rej; | ||
| 429 | + }); | ||
| 430 | + | ||
| 431 | + return { promise, resolve, reject }; | ||
| 432 | + } | ||
| 433 | + | ||
| 423 | 434 | module.exports = { | |
| 424 | 435 | assertCrypto, | |
| 425 | 436 | cachedResult, | |
| 426 | 437 | convertToValidSignal, | |
| 427 | 438 | createClassWrapper, | |
| 439 | + createDeferredPromise, | ||
| 428 | 440 | decorateErrorStack, | |
| 429 | 441 | deprecate, | |
| 430 | 442 | emitExperimentalWarning, | |
| Back | FazBrowse Home | New Git URL |
0 commit comments