"use strict"; module.exports = function(Promise, PromiseArray, apiRejection, debug) { var util = require("./util"); var tryCatch = util.tryCatch; var errorObj = util.errorObj; var async = Promise._async; Promise.prototype["break"] = Promise.prototype.cancel = function() { if (!debug.cancellation()) return this._warn("cancellation is disabled"); var promise = this; var child = promise; while (promise._isCancellable()) { if (!promise._cancelBy(child)) { if (child._isFollowing()) { child._followee().cancel(); } else { child._cancelBranched(); } break; } var parent = promise._cancellationParent; if (parent == null || !parent._isCancellable()) { if (promise._isFollowing()) { promise._followee().cancel(); } else { promise._cancelBranched(); } break; } else { if (promise._isFollowing()) promise._followee().cancel(); promise._setWillBeCancelled(); child = promise; promise = parent; } } }; Promise.prototype._branchHasCancelled = function() { this._branchesRemainingToCancel--; }; Promise.prototype._enoughBranchesHaveCancelled = function() { return this._branchesRemainingToCancel === undefined || this._branchesRemainingToCancel <= 0; }; Promise.prototype._cancelBy = function(canceller) { if (canceller === this) { this._branchesRemainingToCancel = 0; this._invokeOnCancel(); return true; } else { this._branchHasCancelled(); if (this._enoughBranchesHaveCancelled()) { this._invokeOnCancel(); return true; } } return false; }; Promise.prototype._cancelBranched = function() { if (this._enoughBranchesHaveCancelled()) { this._cancel(); } }; Promise.prototype._cancel = function() { if (!this._isCancellable()) return; this._setCancelled(); async.invoke(this._cancelPromises, this, undefined); }; Promise.prototype._cancelPromises = function() { if (this._length() > 0) this._settlePromises(); }; Promise.prototype._unsetOnCancel = function() { this._onCancelField = undefined; }; Promise.prototype._isCancellable = function() { return this.isPending() && !this._isCancelled(); }; Promise.prototype.isCancellable = function() { return this.isPending() && !this.isCancelled(); }; Promise.prototype._doInvokeOnCancel = function(onCancelCallback, internalOnly) { if (util.isArray(onCancelCallback)) { for (var i = 0; i < onCancelCallback.length; ++i) { this._doInvokeOnCancel(onCancelCallback[i], internalOnly); } } else if (onCancelCallback !== undefined) { if (typeof onCancelCallback === "function") { if (!internalOnly) { var e = tryCatch(onCancelCallback).call(this._boundValue()); if (e === errorObj) { this._attachExtraTrace(e.e); async.throwLater(e.e); } } } else { onCancelCallback._resultCancelled(this); } } }; Promise.prototype._invokeOnCancel = function() { var onCancelCallback = this._onCancel(); this._unsetOnCancel(); async.invoke(this._doInvokeOnCancel, this, onCancelCallback); }; Promise.prototype._invokeInternalOnCancel = function() { if (this._isCancellable()) { this._doInvokeOnCancel(this._onCancel(), true); this._unsetOnCancel(); } }; Promise.prototype._resultCancelled = function() { this.cancel(); }; };
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 |
|