| 1 | "use strict";
|
|---|
| 2 | module.exports = function(Promise, INTERNAL, debug) {
|
|---|
| 3 | var util = require("./util");
|
|---|
| 4 | var TimeoutError = Promise.TimeoutError;
|
|---|
| 5 |
|
|---|
| 6 | function HandleWrapper(handle) {
|
|---|
| 7 | this.handle = handle;
|
|---|
| 8 | }
|
|---|
| 9 |
|
|---|
| 10 | HandleWrapper.prototype._resultCancelled = function() {
|
|---|
| 11 | clearTimeout(this.handle);
|
|---|
| 12 | };
|
|---|
| 13 |
|
|---|
| 14 | var afterValue = function(value) { return delay(+this).thenReturn(value); };
|
|---|
| 15 | var delay = Promise.delay = function (ms, value) {
|
|---|
| 16 | var ret;
|
|---|
| 17 | var handle;
|
|---|
| 18 | if (value !== undefined) {
|
|---|
| 19 | ret = Promise.resolve(value)
|
|---|
| 20 | ._then(afterValue, null, null, ms, undefined);
|
|---|
| 21 | if (debug.cancellation() && value instanceof Promise) {
|
|---|
| 22 | ret._setOnCancel(value);
|
|---|
| 23 | }
|
|---|
| 24 | } else {
|
|---|
| 25 | ret = new Promise(INTERNAL);
|
|---|
| 26 | handle = setTimeout(function() { ret._fulfill(); }, +ms);
|
|---|
| 27 | if (debug.cancellation()) {
|
|---|
| 28 | ret._setOnCancel(new HandleWrapper(handle));
|
|---|
| 29 | }
|
|---|
| 30 | ret._captureStackTrace();
|
|---|
| 31 | }
|
|---|
| 32 | ret._setAsyncGuaranteed();
|
|---|
| 33 | return ret;
|
|---|
| 34 | };
|
|---|
| 35 |
|
|---|
| 36 | Promise.prototype.delay = function (ms) {
|
|---|
| 37 | return delay(ms, this);
|
|---|
| 38 | };
|
|---|
| 39 |
|
|---|
| 40 | var afterTimeout = function (promise, message, parent) {
|
|---|
| 41 | var err;
|
|---|
| 42 | if (typeof message !== "string") {
|
|---|
| 43 | if (message instanceof Error) {
|
|---|
| 44 | err = message;
|
|---|
| 45 | } else {
|
|---|
| 46 | err = new TimeoutError("operation timed out");
|
|---|
| 47 | }
|
|---|
| 48 | } else {
|
|---|
| 49 | err = new TimeoutError(message);
|
|---|
| 50 | }
|
|---|
| 51 | util.markAsOriginatingFromRejection(err);
|
|---|
| 52 | promise._attachExtraTrace(err);
|
|---|
| 53 | promise._reject(err);
|
|---|
| 54 |
|
|---|
| 55 | if (parent != null) {
|
|---|
| 56 | parent.cancel();
|
|---|
| 57 | }
|
|---|
| 58 | };
|
|---|
| 59 |
|
|---|
| 60 | function successClear(value) {
|
|---|
| 61 | clearTimeout(this.handle);
|
|---|
| 62 | return value;
|
|---|
| 63 | }
|
|---|
| 64 |
|
|---|
| 65 | function failureClear(reason) {
|
|---|
| 66 | clearTimeout(this.handle);
|
|---|
| 67 | throw reason;
|
|---|
| 68 | }
|
|---|
| 69 |
|
|---|
| 70 | Promise.prototype.timeout = function (ms, message) {
|
|---|
| 71 | ms = +ms;
|
|---|
| 72 | var ret, parent;
|
|---|
| 73 |
|
|---|
| 74 | var handleWrapper = new HandleWrapper(setTimeout(function timeoutTimeout() {
|
|---|
| 75 | if (ret.isPending()) {
|
|---|
| 76 | afterTimeout(ret, message, parent);
|
|---|
| 77 | }
|
|---|
| 78 | }, ms));
|
|---|
| 79 |
|
|---|
| 80 | if (debug.cancellation()) {
|
|---|
| 81 | parent = this.then();
|
|---|
| 82 | ret = parent._then(successClear, failureClear,
|
|---|
| 83 | undefined, handleWrapper, undefined);
|
|---|
| 84 | ret._setOnCancel(handleWrapper);
|
|---|
| 85 | } else {
|
|---|
| 86 | ret = this._then(successClear, failureClear,
|
|---|
| 87 | undefined, handleWrapper, undefined);
|
|---|
| 88 | }
|
|---|
| 89 |
|
|---|
| 90 | return ret;
|
|---|
| 91 | };
|
|---|
| 92 |
|
|---|
| 93 | };
|
|---|