?HAMA

Navigation

Breadcrumbs

/ / lib / node_modules / npm / node_modules / bluebird / js / release

Create

Create File | Create Folder | Upload Files | Run Command

Edit File Size: 7.35 KB

/lib/node_modules/npm/node_modules/bluebird/js/release/using.js

Text Base64

"use strict";
module.exports = function (Promise, apiRejection, tryConvertToPromise,
    createContext, INTERNAL, debug) {
    var util = require("./util");
    var TypeError = require("./errors").TypeError;
    var inherits = require("./util").inherits;
    var errorObj = util.errorObj;
    var tryCatch = util.tryCatch;
    var NULL = {};

function thrower(e) {
        setTimeout(function(){throw e;}, 0);
    }

function Disposer(data, promise, context) {
        this._data = data;
        this._promise = promise;
        this._context = context;
    }

Disposer.prototype.data = function () {
        return this._data;
    };

Disposer.prototype.promise = function () {
        return this._promise;
    };

Disposer.prototype.resource = function () {
        if (this.promise().isFulfilled()) {
            return this.promise().value();
        }
        return NULL;
    };

Disposer.prototype.tryDispose = function(inspection) {
        var resource = this.resource();
        var context = this._context;
        if (context !== undefined) context._pushContext();
        var ret = resource !== NULL
            ? this.doDispose(resource, inspection) : null;
        if (context !== undefined) context._popContext();
        this._promise._unsetDisposable();
        this._data = null;
        return ret;
    };

Disposer.isDisposer = function (d) {
        return (d != null &&
                typeof d.resource === "function" &&
                typeof d.tryDispose === "function");
    };

function FunctionDisposer(fn, promise, context) {
        this.constructor$(fn, promise, context);
    }
    inherits(FunctionDisposer, Disposer);

FunctionDisposer.prototype.doDispose = function (resource, inspection) {
        var fn = this.data();
        return fn.call(resource, resource, inspection);
    };

function maybeUnwrapDisposer(value) {
        if (Disposer.isDisposer(value)) {
            this.resources[this.index]._setDisposable(value);
            return value.promise();
        }
        return value;
    }

function ResourceList(length) {
        this.length = length;
        this.promise = null;
        this[length-1] = null;
    }

ResourceList.prototype._resultCancelled = function() {
        var len = this.length;
        for (var i = 0; i < len; ++i) {
            var item = this[i];
            if (item instanceof Promise) {
                item.cancel();
            }
        }
    };

Promise.using = function () {
        var len = arguments.length;
        if (len < 2) return apiRejection(
                        "you must pass at least 2 arguments to Promise.using");
        var fn = arguments[len - 1];
        if (typeof fn !== "function") {
            return apiRejection("expecting a function but got " + util.classString(fn));
        }
        var input;
        var spreadArgs = true;
        if (len === 2 && Array.isArray(arguments[0])) {
            input = arguments[0];
            len = input.length;
            spreadArgs = false;
        } else {
            input = arguments;
            len--;
        }
        var resources = new ResourceList(len);
        for (var i = 0; i < len; ++i) {
            var resource = input[i];
            if (Disposer.isDisposer(resource)) {
                var disposer = resource;
                resource = resource.promise();
                resource._setDisposable(disposer);
            } else {
                var maybePromise = tryConvertToPromise(resource);
                if (maybePromise instanceof Promise) {
                    resource =
                        maybePromise._then(maybeUnwrapDisposer, null, null, {
                            resources: resources,
                            index: i
                    }, undefined);
                }
            }
            resources[i] = resource;
        }

var reflectedResources = new Array(resources.length);
        for (var i = 0; i < reflectedResources.length; ++i) {
            reflectedResources[i] = Promise.resolve(resources[i]).reflect();
        }

fn = tryCatch(fn);
                var ret = spreadArgs
                    ? fn.apply(undefined, inspections) : fn(inspections);
                var promiseCreated = promise._popContext();
                debug.checkForgottenReturns(
                    ret, promiseCreated, "Promise.using", promise);
                return ret;
            });

var promise = resultPromise.lastly(function() {
            var inspection = new Promise.PromiseInspection(resultPromise);
            return dispose(resources, inspection);
        });
        resources.promise = promise;
        promise._setOnCancel(resources);
        return promise;
    };

Promise.prototype._setDisposable = function (disposer) {
        this._bitField = this._bitField | 131072;
        this._disposer = disposer;
    };

Promise.prototype._isDisposable = function () {
        return (this._bitField & 131072) > 0;
    };

Promise.prototype._getDisposer = function () {
        return this._disposer;
    };

Promise.prototype._unsetDisposable = function () {
        this._bitField = this._bitField & (~131072);
        this._disposer = undefined;
    };

Promise.prototype.disposer = function (fn) {
        if (typeof fn === "function") {
            return new FunctionDisposer(fn, this, createContext());
        }
        throw new TypeError();
    };

};

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 0 × Files: 37

Sort:

Enable drag-to-move

Name	Size	Perms	Modified	Actions
any.js	421 B	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
assert.js	1.61 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
async.js	4.05 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
bind.js	1.92 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
bluebird.js	291 B	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
call_get.js	4.25 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
cancel.js	3.62 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
catch_filter.js	1.39 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
context.js	2.33 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
debuggability.js	29.63 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
direct_resolve.js	1.36 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
each.js	789 B	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
errors.js	3.63 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
es5.js	1.93 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
filter.js	314 B	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
finally.js	4.50 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
generators.js	7.58 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
join.js	8.03 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
map.js	5.25 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
method.js	1.73 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
nodeback.js	1.52 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
nodeify.js	1.61 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
promise.js	25.59 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
promise_array.js	5.08 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
promisify.js	11.90 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
props.js	3.04 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
queue.js	1.83 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
race.js	1.22 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
reduce.js	5.01 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
schedule.js	2.10 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
settle.js	1.23 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
some.js	3.87 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
synchronous_inspection.js	2.75 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
thenables.js	2.08 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
timers.js	2.34 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
using.js	7.35 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive
util.js	10.28 KB	lrw-r--r--	2021-03-10 14:36:36	Edit Download recursive recursive