MeshCentral/MeshAgent
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshAgent synced 2026-01-16 15:33:16 +00:00
Code Issues Releases Wiki Activity

1. Updated reference counting in promise

Browse Source 
2. Added 'internal' prototype to Function, which sets infrastructure mode
This commit is contained in:
Bryan Roe
2021-03-03 22:48:58 -08:00
parent ac1164b52e
commit 8ac6fb4309
3 changed files with 53 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
modules/promise.js
View File

@@ -59,9 +59,7 @@ function Promise(promiseFunc)
}
});
this._internal.on('newListener', function (eventName, eventCallback)
this._internal.on('newListener', (function (eventName, eventCallback)
{
//console.log('newListener', eventName, 'errors/' + this.errors + ' completed/' + this.completed);
var r = null;
@@ -99,8 +97,9 @@ function Promise(promiseFunc)
{
eventCallback.apply(this, []);
}
});
this._internal.resolver = function _resolver()
}).internal);
this._internal.resolver = (function _resolver()
{
if (_resolver._self.completed) { return; }
_resolver._self.errors = false;
@@ -143,8 +142,8 @@ function Promise(promiseFunc)
_resolver._self.emit.apply(_resolver._self, args);
_resolver._self.emit('settled');
}
};
this._internal.rejector = function _rejector()
}).internal;
this._internal.rejector = (function _rejector()
{
if (_rejector._self.completed) { return; }
_rejector._self.errors = true;
@@ -168,24 +167,24 @@ function Promise(promiseFunc)
_rejector._self.emit.apply(_rejector._self, args);
_rejector._self.emit('settled');
};
}).internal;
this._internal.rejector.internal = true;
this.catch = function(func)
{
var rt = getRootPromise(this);
this._internal.once('rejected', event_switcher(this, func).func);
this._internal.once('rejected', event_switcher(this, func).func.internal);
}
this.finally = function (func)
{
this._internal.once('settled', event_switcher(this, func).func);
this._internal.once('settled', event_switcher(this, func).func.internal);
};
this.then = function (resolved, rejected)
{
if (resolved) { this._internal.once('resolved', event_switcher(this, resolved).func); }
if (resolved) { this._internal.once('resolved', event_switcher(this, resolved).func.internal); }
if (rejected)
{
this._internal.once('rejected', event_switcher(this, rejected).func);
this._internal.once('rejected', event_switcher(this, rejected).func.internal);
}
var retVal = new Promise(function (r, j) { this._rej = j; });
@@ -220,6 +219,7 @@ function Promise(promiseFunc)
this._internal.once('rejected', retVal._internal.rejector);
}
this.__childPromise = retVal;
return (retVal);
};
@@ -243,7 +243,10 @@ function Promise(promiseFunc)
{
// Save reference of this object
refTable[this._internal._hashCode()] = this._internal;
this._internal.once('settled', function () { delete refTable[this._hashCode()]; });
this._internal.once('settled', (function ()
{
delete refTable[this._hashCode()];
}).internal);
}
Object.defineProperty(this, "completed", {
get: function ()
@@ -251,6 +254,19 @@ function Promise(promiseFunc)
return (this._internal.completed);
}
});
this._internal.once('settled', (function ()
{
delete this.resolver._self;
delete this.rejector._self;
delete this.promise._up;
delete this.promise.__childPromise;
delete this.promise.promise;
delete this._up;
delete this.__childPromise;
delete this.promise;
}).internal);
}
Promise.resolve = function resolve()