File: assimilate.js

package info (click to toggle)
node-tad 3.1.1%2B~cs11.22.49-1
  • links: PTS, VCS
  • area: main
  • in suites: sid, trixie
  • size: 3,400 kB
  • sloc: javascript: 25,549; makefile: 6
file content (45 lines) | stat: -rw-r--r-- 1,232 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
// Assimilate eventual foreign promise

"use strict";

var isObject  = require("es5-ext/object/is-object")
  , isPromise = require("./is-promise")
  , deferred  = require("./deferred")
  , nextTick  = require("next-tick");

var getPrototypeOf = Object.getPrototypeOf;

module.exports = function self(value) {
	var then, done, def, resolve, reject;
	if (!value) return value;
	try { then = value.then; }
	catch (e) { return value; }
	if (typeof then !== "function") return value;
	if (isPromise(value)) return value;
	if (!isObject(value)) return value;
	if (!getPrototypeOf(value)) return value;
	try { done = value.done; }
	catch (ignore) {}
	def = deferred();
	resolve = function (resolvedValue) { def.resolve(self(resolvedValue)); };
	reject = function (resolvedReason) { def.reject(resolvedReason); };
	if (typeof done === "function") {
		try { done.call(value, resolve, reject); }
		catch (e) { return def.reject(e); }
		return def.promise;
	}
	try {
		then.call(
			value,
			function (resolvedValue) {
				nextTick(function () { resolve(resolvedValue); });
			},
			function (resolvedReason) {
				nextTick(function () { reject(resolvedReason); });
			}
		);
	} catch (e) {
		return def.reject(e);
	}
	return def.promise;
};