__ __ __ __ _____ _ _ _____ _ _ _ | \/ | \ \ / / | __ \ (_) | | / ____| | | | | | \ / |_ __\ V / | |__) | __ ___ ____ _| |_ ___ | (___ | |__ ___| | | | |\/| | '__|> < | ___/ '__| \ \ / / _` | __/ _ \ \___ \| '_ \ / _ \ | | | | | | |_ / . \ | | | | | |\ V / (_| | || __/ ____) | | | | __/ | | |_| |_|_(_)_/ \_\ |_| |_| |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1 if you need WebShell for Seo everyday contact me on Telegram Telegram Address : @jackleetFor_More_Tools:
"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 |
|