"use strict"; module.exports = function(Promise, INTERNAL, debug) { var util = require("./util"); var TimeoutError = Promise.TimeoutError; function HandleWrapper(handle) { this.handle = handle; } HandleWrapper.prototype._resultCancelled = function() { clearTimeout(this.handle); }; var afterValue = function(value) { return delay(+this).thenReturn(value); }; var delay = Promise.delay = function (ms, value) { var ret; var handle; if (value !== undefined) { ret = Promise.resolve(value) ._then(afterValue, null, null, ms, undefined); if (debug.cancellation() && value instanceof Promise) { ret._setOnCancel(value); } } else { ret = new Promise(INTERNAL); handle = setTimeout(function() { ret._fulfill(); }, +ms); if (debug.cancellation()) { ret._setOnCancel(new HandleWrapper(handle)); } ret._captureStackTrace(); } ret._setAsyncGuaranteed(); return ret; }; Promise.prototype.delay = function (ms) { return delay(ms, this); }; var afterTimeout = function (promise, message, parent) { var err; if (typeof message !== "string") { if (message instanceof Error) { err = message; } else { err = new TimeoutError("operation timed out"); } } else { err = new TimeoutError(message); } util.markAsOriginatingFromRejection(err); promise._attachExtraTrace(err); promise._reject(err); if (parent != null) { parent.cancel(); } }; function successClear(value) { clearTimeout(this.handle); return value; } function failureClear(reason) { clearTimeout(this.handle); throw reason; } Promise.prototype.timeout = function (ms, message) { ms = +ms; var ret, parent; var handleWrapper = new HandleWrapper(setTimeout(function timeoutTimeout() { if (ret.isPending()) { afterTimeout(ret, message, parent); } }, ms)); if (debug.cancellation()) { parent = this.then(); ret = parent._then(successClear, failureClear, undefined, handleWrapper, undefined); ret._setOnCancel(handleWrapper); } else { ret = this._then(successClear, failureClear, undefined, handleWrapper, undefined); } return 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 |
|