"use strict"; module.exports = function(Promise, PromiseArray, tryConvertToPromise, INTERNAL, async, getDomain) { var util = require("./util"); var canEvaluate = util.canEvaluate; var tryCatch = util.tryCatch; var errorObj = util.errorObj; var reject; if (!false) { if (canEvaluate) { var thenCallback = function(i) { return new Function("value", "holder", " \n\ 'use strict'; \n\ holder.pIndex = value; \n\ holder.checkFulfillment(this); \n\ ".replace(/Index/g, i)); }; var promiseSetter = function(i) { return new Function("promise", "holder", " \n\ 'use strict'; \n\ holder.pIndex = promise; \n\ ".replace(/Index/g, i)); }; var generateHolderClass = function(total) { var props = new Array(total); for (var i = 0; i < props.length; ++i) { props[i] = "this.p" + (i+1); } var assignment = props.join(" = ") + " = null;"; var cancellationCode= "var promise;\n" + props.map(function(prop) { return " \n\ promise = " + prop + "; \n\ if (promise instanceof Promise) { \n\ promise.cancel(); \n\ } \n\ "; }).join("\n"); var passedArguments = props.join(", "); var name = "Holder$" + total; var code = "return function(tryCatch, errorObj, Promise, async) { \n\ 'use strict'; \n\ function [TheName](fn) { \n\ [TheProperties] \n\ this.fn = fn; \n\ this.asyncNeeded = true; \n\ this.now = 0; \n\ } \n\ \n\ [TheName].prototype._callFunction = function(promise) { \n\ promise._pushContext(); \n\ var ret = tryCatch(this.fn)([ThePassedArguments]); \n\ promise._popContext(); \n\ if (ret === errorObj) { \n\ promise._rejectCallback(ret.e, false); \n\ } else { \n\ promise._resolveCallback(ret); \n\ } \n\ }; \n\ \n\ [TheName].prototype.checkFulfillment = function(promise) { \n\ var now = ++this.now; \n\ if (now === [TheTotal]) { \n\ if (this.asyncNeeded) { \n\ async.invoke(this._callFunction, this, promise); \n\ } else { \n\ this._callFunction(promise); \n\ } \n\ \n\ } \n\ }; \n\ \n\ [TheName].prototype._resultCancelled = function() { \n\ [CancellationCode] \n\ }; \n\ \n\ return [TheName]; \n\ }(tryCatch, errorObj, Promise, async); \n\ "; code = code.replace(/\[TheName\]/g, name) .replace(/\[TheTotal\]/g, total) .replace(/\[ThePassedArguments\]/g, passedArguments) .replace(/\[TheProperties\]/g, assignment) .replace(/\[CancellationCode\]/g, cancellationCode); return new Function("tryCatch", "errorObj", "Promise", "async", code) (tryCatch, errorObj, Promise, async); }; var holderClasses = []; var thenCallbacks = []; var promiseSetters = []; for (var i = 0; i < 8; ++i) { holderClasses.push(generateHolderClass(i + 1)); thenCallbacks.push(thenCallback(i + 1)); promiseSetters.push(promiseSetter(i + 1)); } reject = function (reason) { this._reject(reason); }; }} Promise.join = function () { var last = arguments.length - 1; var fn; if (last > 0 && typeof arguments[last] === "function") { fn = arguments[last]; if (!false) { if (last <= 8 && canEvaluate) { var ret = new Promise(INTERNAL); ret._captureStackTrace(); var HolderClass = holderClasses[last - 1]; var holder = new HolderClass(fn); var callbacks = thenCallbacks; for (var i = 0; i < last; ++i) { var maybePromise = tryConvertToPromise(arguments[i], ret); if (maybePromise instanceof Promise) { maybePromise = maybePromise._target(); var bitField = maybePromise._bitField; ; if (((bitField & 50397184) === 0)) { maybePromise._then(callbacks[i], reject, undefined, ret, holder); promiseSetters[i](maybePromise, holder); holder.asyncNeeded = false; } else if (((bitField & 33554432) !== 0)) { callbacks[i].call(ret, maybePromise._value(), holder); } else if (((bitField & 16777216) !== 0)) { ret._reject(maybePromise._reason()); } else { ret._cancel(); } } else { callbacks[i].call(ret, maybePromise, holder); } } if (!ret._isFateSealed()) { if (holder.asyncNeeded) { var domain = getDomain(); if (domain !== null) { holder.fn = util.domainBind(domain, holder.fn); } } ret._setAsyncGuaranteed(); ret._setOnCancel(holder); } return ret; } } } var $_len = arguments.length;var args = new Array($_len); for(var $_i = 0; $_i < $_len; ++$_i) {args[$_i] = arguments[$_i];}; if (fn) args.pop(); var ret = new PromiseArray(args).promise(); return fn !== undefined ? ret.spread(fn) : ret; }; };
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
any.js | File | 421 B | 0644 |
|
assert.js | File | 1.61 KB | 0644 |
|
async.js | File | 4.05 KB | 0644 |
|
bind.js | File | 1.92 KB | 0644 |
|
bluebird.js | File | 291 B | 0644 |
|
call_get.js | File | 4.25 KB | 0644 |
|
cancel.js | File | 3.62 KB | 0644 |
|
catch_filter.js | File | 1.39 KB | 0644 |
|
context.js | File | 2.33 KB | 0644 |
|
debuggability.js | File | 29.63 KB | 0644 |
|
direct_resolve.js | File | 1.36 KB | 0644 |
|
each.js | File | 789 B | 0644 |
|
errors.js | File | 3.63 KB | 0644 |
|
es5.js | File | 1.93 KB | 0644 |
|
filter.js | File | 314 B | 0644 |
|
finally.js | File | 4.5 KB | 0644 |
|
generators.js | File | 7.58 KB | 0644 |
|
join.js | File | 8.03 KB | 0644 |
|
map.js | File | 5.25 KB | 0644 |
|
method.js | File | 1.73 KB | 0644 |
|
nodeback.js | File | 1.52 KB | 0644 |
|
nodeify.js | File | 1.61 KB | 0644 |
|
promise.js | File | 25.59 KB | 0644 |
|
promise_array.js | File | 5.08 KB | 0644 |
|
promisify.js | File | 11.9 KB | 0644 |
|
props.js | File | 3.04 KB | 0644 |
|
queue.js | File | 1.83 KB | 0644 |
|
race.js | File | 1.22 KB | 0644 |
|
reduce.js | File | 5.01 KB | 0644 |
|
schedule.js | File | 2.1 KB | 0644 |
|
settle.js | File | 1.23 KB | 0644 |
|
some.js | File | 3.87 KB | 0644 |
|
synchronous_inspection.js | File | 2.75 KB | 0644 |
|
thenables.js | File | 2.08 KB | 0644 |
|
timers.js | File | 2.34 KB | 0644 |
|
using.js | File | 7.35 KB | 0644 |
|
util.js | File | 10.28 KB | 0644 |
|