|
| 1 | +'use strict'; |
| 2 | +var $ = require('../internals/export'); |
| 3 | +var aCallable = require('../internals/a-callable'); |
| 4 | +var anObject = require('../internals/an-object'); |
| 5 | +var call = require('../internals/function-call'); |
| 6 | +var createProperty = require('../internals/create-property'); |
| 7 | +var getBuiltInStaticMethod = require('../internals/get-built-in-static-method'); |
| 8 | +var getOwnPropertyDescriptor = require('../internals/object-get-own-property-descriptor'); |
| 9 | +var newPromiseCapabilityModule = require('../internals/new-promise-capability'); |
| 10 | +var perform = require('../internals/perform'); |
| 11 | +var uncurryThis = require('../internals/function-uncurry-this'); |
| 12 | + |
| 13 | +var create = Object.create; |
| 14 | +var forEach = uncurryThis([].forEach); |
| 15 | +// dependency: es.reflect.own-keys |
| 16 | +var ownKeys = getBuiltInStaticMethod('Reflect', 'ownKeys'); |
| 17 | + |
| 18 | +// `Promise.allSettledKeyed` method |
| 19 | +// https://tc39.es/proposal-await-dictionary |
| 20 | +$({ target: 'Promise', stat: true, forced: true }, { |
| 21 | + allSettledKeyed: function allSettledKeyed(promises) { |
| 22 | + var C = this; |
| 23 | + // dependency: es.promise.constructor |
| 24 | + // dependency: es.promise.catch |
| 25 | + // dependency: es.promise.finally |
| 26 | + // dependency: es.promise.resolve |
| 27 | + var capability = newPromiseCapabilityModule.f(C); |
| 28 | + var resolve = capability.resolve; |
| 29 | + var reject = capability.reject; |
| 30 | + var result = perform(function () { |
| 31 | + var promiseResolve = aCallable(C.resolve); |
| 32 | + var allKeys = ownKeys(anObject(promises)); |
| 33 | + var keys = []; |
| 34 | + var values = []; |
| 35 | + var remaining = 1; |
| 36 | + var counter = 0; |
| 37 | + forEach(allKeys, function (key) { |
| 38 | + var desc = getOwnPropertyDescriptor.f(promises, key); |
| 39 | + if (desc && desc.enumerable) { |
| 40 | + var createElementResolver = function (rejection) { |
| 41 | + return function (value) { |
| 42 | + if (alreadyCalled) return; |
| 43 | + alreadyCalled = true; |
| 44 | + values[index] = rejection |
| 45 | + ? { status: 'rejected', reason: value } |
| 46 | + : { status: 'fulfilled', value: value }; |
| 47 | + if (--remaining) return; |
| 48 | + var res = create(null); |
| 49 | + forEach(keys, function (k, i) { |
| 50 | + createProperty(res, k, values[i]); |
| 51 | + }); |
| 52 | + resolve(res); |
| 53 | + }; |
| 54 | + }; |
| 55 | + var index = counter; |
| 56 | + var alreadyCalled = false; |
| 57 | + remaining++; |
| 58 | + keys[index] = key; |
| 59 | + values[index] = undefined; |
| 60 | + call(promiseResolve, C, promises[key]).then(createElementResolver(false), createElementResolver(true)); |
| 61 | + counter++; |
| 62 | + } |
| 63 | + }); |
| 64 | + --remaining || resolve(create(null)); |
| 65 | + }); |
| 66 | + if (result.error) reject(result.value); |
| 67 | + return capability.promise; |
| 68 | + }, |
| 69 | +}); |
0 commit comments