stream: simplify `createPromiseCallback` · nodejs/node@f00cdab

MathMax,

NumberIsNaN,

PromisePrototypeThen,

ReflectApply,

ReflectGet,

Symbol,

SymbolAsyncIterator,

controller[kState].queueTotalSize += size;

}

// This implements "invoke a callback function type" for callback functions that return a promise.

// See https://webidl.spec.whatwg.org/#es-invoking-callback-functions

async function invokePromiseCallback(fn, thisArg, ...args) {

return FunctionPrototypeCall(fn, thisArg, ...args);

}

function createPromiseCallback(name, fn, thisArg) {

validateFunction(fn, name);

return (...args) => invokePromiseCallback(fn, thisArg, ...args);

return async (...args) => ReflectApply(fn, thisArg, args);

}

function isPromisePending(promise) {

extractHighWaterMark,

extractSizeAlgorithm,

lazyTransfer,

invokePromiseCallback,

isBrandCheck,

isPromisePending,

peekQueueValue,