"use strict"; module.exports = function(Promise, tryConvertToPromise, NEXT_FILTER) { var util = require("./util"); var CancellationError = Promise.CancellationError; var errorObj = util.errorObj; var catchFilter = require("./catch_filter")(NEXT_FILTER); function PassThroughHandlerContext(promise, type, handler) { this.promise = promise; this.type = type; this.handler = handler; this.called = false; this.cancelPromise = null; } PassThroughHandlerContext.prototype.isFinallyHandler = function() { return this.type === 0; }; function FinallyHandlerCancelReaction(finallyHandler) { this.finallyHandler = finallyHandler; } FinallyHandlerCancelReaction.prototype._resultCancelled = function() { checkCancel(this.finallyHandler); }; function checkCancel(ctx, reason) { if (ctx.cancelPromise != null) { if (arguments.length > 1) { ctx.cancelPromise._reject(reason); } else { ctx.cancelPromise._cancel(); } ctx.cancelPromise = null; return true; } return false; } function succeed() { return finallyHandler.call(this, this.promise._target()._settledValue()); } function fail(reason) { if (checkCancel(this, reason)) return; errorObj.e = reason; return errorObj; } function finallyHandler(reasonOrValue) { var promise = this.promise; var handler = this.handler; if (!this.called) { this.called = true; var ret = this.isFinallyHandler() ? handler.call(promise._boundValue()) : handler.call(promise._boundValue(), reasonOrValue); if (ret === NEXT_FILTER) { return ret; } else if (ret !== undefined) { promise._setReturnedNonUndefined(); var maybePromise = tryConvertToPromise(ret, promise); if (maybePromise instanceof Promise) { if (this.cancelPromise != null) { if (maybePromise._isCancelled()) { var reason = new CancellationError("late cancellation observer"); promise._attachExtraTrace(reason); errorObj.e = reason; return errorObj; } else if (maybePromise.isPending()) { maybePromise._attachCancellationCallback( new FinallyHandlerCancelReaction(this)); } } return maybePromise._then( succeed, fail, undefined, this, undefined); } } } if (promise.isRejected()) { checkCancel(this); errorObj.e = reasonOrValue; return errorObj; } else { checkCancel(this); return reasonOrValue; } } Promise.prototype._passThrough = function(handler, type, success, fail) { if (typeof handler !== "function") return this.then(); return this._then(success, fail, undefined, new PassThroughHandlerContext(this, type, handler), undefined); }; Promise.prototype.lastly = Promise.prototype["finally"] = function (handler) { return this._passThrough(handler, 0, finallyHandler, finallyHandler); }; Promise.prototype.tap = function (handler) { return this._passThrough(handler, 1, finallyHandler); }; Promise.prototype.tapCatch = function (handlerOrPredicate) { var len = arguments.length; if(len === 1) { return this._passThrough(handlerOrPredicate, 1, undefined, finallyHandler); } else { var catchInstances = new Array(len - 1), j = 0, i; for (i = 0; i < len - 1; ++i) { var item = arguments[i]; if (util.isObject(item)) { catchInstances[j++] = item; } else { return Promise.reject(new TypeError( "tapCatch statement predicate: " + "expecting an object but got " + util.classString(item) )); } } catchInstances.length = j; var handler = arguments[i]; return this._passThrough(catchFilter(catchInstances, handler, this), 1, undefined, finallyHandler); } }; return PassThroughHandlerContext; };
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 |
|