diff --git a/lib/child_process.js b/lib/child_process.js index fedce463c6bebc..3fb21f755be3d7 100644 --- a/lib/child_process.js +++ b/lib/child_process.js @@ -37,13 +37,13 @@ const { ObjectAssign, ObjectDefineProperty, ObjectPrototypeHasOwnProperty, + PromiseWithResolvers, RegExpPrototypeExec, SafeSet, StringPrototypeIncludes, StringPrototypeSlice, StringPrototypeToUpperCase, SymbolDispose, - PromiseWithResolvers, } = primordials; const { diff --git a/lib/internal/abort_controller.js b/lib/internal/abort_controller.js index 0dff4116f93537..b812f588c23e99 100644 --- a/lib/internal/abort_controller.js +++ b/lib/internal/abort_controller.js @@ -10,12 +10,12 @@ const { ObjectDefineProperty, ObjectSetPrototypeOf, PromiseResolve, + PromiseWithResolvers, SafeFinalizationRegistry, SafeSet, SafeWeakRef, Symbol, SymbolToStringTag, - PromiseWithResolvers, } = primordials; const { diff --git a/lib/internal/blob.js b/lib/internal/blob.js index 7334dc5539839c..43a7ae5ac34d9c 100644 --- a/lib/internal/blob.js +++ b/lib/internal/blob.js @@ -9,6 +9,7 @@ const { ObjectSetPrototypeOf, PromisePrototypeThen, PromiseReject, + PromiseWithResolvers, RegExpPrototypeExec, RegExpPrototypeSymbolReplace, StringPrototypeSplit, @@ -17,7 +18,6 @@ const { SymbolIterator, SymbolToStringTag, Uint8Array, - PromiseWithResolvers, } = primordials; const { @@ -478,7 +478,7 @@ function createBlobFromFilePath(path, options) { } function arrayBuffer(blob) { - const { promise, resolve, reject } = createDeferredPromise(); + const { promise, resolve, reject } = PromiseWithResolvers(); const reader = blob[kHandle].getReader(); const buffers = []; const readNext = () => { diff --git a/lib/internal/fs/watchers.js b/lib/internal/fs/watchers.js index e42416b8b70781..efa8dd85c64bfb 100644 --- a/lib/internal/fs/watchers.js +++ b/lib/internal/fs/watchers.js @@ -368,7 +368,7 @@ async function* watch(filename, options = kEmptyObject) { while (!signal?.aborted) { yield await promise; - ({ promise, resolve, reject } = createDeferredPromise()); + ({ promise, resolve, reject } = PromiseWithResolvers()); } throw new AbortError(undefined, { cause: signal?.reason }); } finally { diff --git a/lib/internal/test_runner/runner.js b/lib/internal/test_runner/runner.js index 44453831b55fd4..0ba40d7ba7f71f 100644 --- a/lib/internal/test_runner/runner.js +++ b/lib/internal/test_runner/runner.js @@ -16,9 +16,9 @@ const { ArrayPrototypeSome, ArrayPrototypeSort, ObjectAssign, - PromiseWithResolvers, PromisePrototypeThen, PromiseResolve, + PromiseWithResolvers, SafeMap, SafePromiseAll, SafePromiseAllReturnVoid, diff --git a/lib/internal/webstreams/adapters.js b/lib/internal/webstreams/adapters.js index 97f64ac969b290..4e99d56aa4be7e 100644 --- a/lib/internal/webstreams/adapters.js +++ b/lib/internal/webstreams/adapters.js @@ -5,9 +5,9 @@ const { ArrayPrototypeMap, Boolean, ObjectEntries, - PromiseWithResolvers, PromisePrototypeThen, PromiseResolve, + PromiseWithResolvers, SafePromiseAll, SafePromisePrototypeFinally, SafeSet, diff --git a/lib/internal/webstreams/readablestream.js b/lib/internal/webstreams/readablestream.js index 49fe03c780f51e..2369175733c115 100644 --- a/lib/internal/webstreams/readablestream.js +++ b/lib/internal/webstreams/readablestream.js @@ -16,10 +16,10 @@ const { ObjectDefineProperties, ObjectSetPrototypeOf, Promise, - PromiseWithResolvers, PromisePrototypeThen, PromiseReject, PromiseResolve, + PromiseWithResolvers, SafePromiseAll, Symbol, SymbolAsyncIterator, diff --git a/lib/internal/webstreams/transfer.js b/lib/internal/webstreams/transfer.js index f659ca95a41688..9ce3f249ffd2bd 100644 --- a/lib/internal/webstreams/transfer.js +++ b/lib/internal/webstreams/transfer.js @@ -2,8 +2,8 @@ const { ObjectDefineProperties, - PromiseWithResolvers, PromiseResolve, + PromiseWithResolvers, ReflectConstruct, } = primordials; @@ -178,7 +178,7 @@ class CrossRealmTransformWritableSink { this[kState] = { port, controller: undefined, - backpressurePromise: createDeferredPromise(), + backpressurePromise: PromiseWithResolvers(), unref, }; diff --git a/lib/internal/webstreams/transformstream.js b/lib/internal/webstreams/transformstream.js index 71ca37abbf6fb6..cd3c96d68a59b8 100644 --- a/lib/internal/webstreams/transformstream.js +++ b/lib/internal/webstreams/transformstream.js @@ -4,8 +4,8 @@ const { FunctionPrototypeCall, ObjectDefineProperties, ObjectSetPrototypeOf, - PromiseWithResolvers, PromisePrototypeThen, + PromiseWithResolvers, Symbol, SymbolToStringTag, } = primordials; diff --git a/lib/internal/webstreams/writablestream.js b/lib/internal/webstreams/writablestream.js index 168f0c630cee9f..5baaf20c30ba26 100644 --- a/lib/internal/webstreams/writablestream.js +++ b/lib/internal/webstreams/writablestream.js @@ -8,10 +8,10 @@ const { ObjectDefineProperties, ObjectSetPrototypeOf, Promise, - PromiseWithResolvers, PromisePrototypeThen, PromiseReject, PromiseResolve, + PromiseWithResolvers, Symbol, SymbolToStringTag, } = primordials; @@ -557,7 +557,7 @@ const isWritableStreamDefaultController = function createWritableStreamState() { return { __proto__: null, - close: createDeferredPromise(), + close: PromiseWithResolvers(), closeRequest: { __proto__: null, promise: undefined,