diff --git a/build/esiur.js b/build/esiur.js
index c632be4..e80fd3d 100644
--- a/build/esiur.js
+++ b/build/esiur.js
@@ -65,13 +65,25 @@ function _classApplyDescriptorGet(receiver, descriptor) {
}
module.exports = _classApplyDescriptorGet, module.exports.__esModule = true, module.exports["default"] = module.exports;
},{}],7:[function(require,module,exports){
+function _classApplyDescriptorSet(receiver, descriptor, value) {
+ if (descriptor.set) {
+ descriptor.set.call(receiver, value);
+ } else {
+ if (!descriptor.writable) {
+ throw new TypeError("attempted to set read only private field");
+ }
+ descriptor.value = value;
+ }
+}
+module.exports = _classApplyDescriptorSet, module.exports.__esModule = true, module.exports["default"] = module.exports;
+},{}],8:[function(require,module,exports){
function _classCallCheck(instance, Constructor) {
if (!(instance instanceof Constructor)) {
throw new TypeError("Cannot call a class as a function");
}
}
module.exports = _classCallCheck, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],8:[function(require,module,exports){
+},{}],9:[function(require,module,exports){
function _classExtractFieldDescriptor(receiver, privateMap, action) {
if (!privateMap.has(receiver)) {
throw new TypeError("attempted to " + action + " private field on non-instance");
@@ -79,7 +91,7 @@ function _classExtractFieldDescriptor(receiver, privateMap, action) {
return privateMap.get(receiver);
}
module.exports = _classExtractFieldDescriptor, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],9:[function(require,module,exports){
+},{}],10:[function(require,module,exports){
var classApplyDescriptorGet = require("./classApplyDescriptorGet.js");
var classExtractFieldDescriptor = require("./classExtractFieldDescriptor.js");
function _classPrivateFieldGet(receiver, privateMap) {
@@ -87,26 +99,27 @@ function _classPrivateFieldGet(receiver, privateMap) {
return classApplyDescriptorGet(receiver, descriptor);
}
module.exports = _classPrivateFieldGet, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./classApplyDescriptorGet.js":6,"./classExtractFieldDescriptor.js":8}],10:[function(require,module,exports){
+},{"./classApplyDescriptorGet.js":6,"./classExtractFieldDescriptor.js":9}],11:[function(require,module,exports){
+var classApplyDescriptorSet = require("./classApplyDescriptorSet.js");
+var classExtractFieldDescriptor = require("./classExtractFieldDescriptor.js");
+function _classPrivateFieldSet(receiver, privateMap, value) {
+ var descriptor = classExtractFieldDescriptor(receiver, privateMap, "set");
+ classApplyDescriptorSet(receiver, descriptor, value);
+ return value;
+}
+module.exports = _classPrivateFieldSet, module.exports.__esModule = true, module.exports["default"] = module.exports;
+},{"./classApplyDescriptorSet.js":7,"./classExtractFieldDescriptor.js":9}],12:[function(require,module,exports){
var setPrototypeOf = require("./setPrototypeOf.js");
var isNativeReflectConstruct = require("./isNativeReflectConstruct.js");
-function _construct(Parent, args, Class) {
- if (isNativeReflectConstruct()) {
- module.exports = _construct = Reflect.construct.bind(), module.exports.__esModule = true, module.exports["default"] = module.exports;
- } else {
- module.exports = _construct = function _construct(Parent, args, Class) {
- var a = [null];
- a.push.apply(a, args);
- var Constructor = Function.bind.apply(Parent, a);
- var instance = new Constructor();
- if (Class) setPrototypeOf(instance, Class.prototype);
- return instance;
- }, module.exports.__esModule = true, module.exports["default"] = module.exports;
- }
- return _construct.apply(null, arguments);
+function _construct(t, e, r) {
+ if (isNativeReflectConstruct()) return Reflect.construct.apply(null, arguments);
+ var o = [null];
+ o.push.apply(o, e);
+ var p = new (t.bind.apply(t, o))();
+ return r && setPrototypeOf(p, r.prototype), p;
}
module.exports = _construct, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./isNativeReflectConstruct.js":18,"./setPrototypeOf.js":25}],11:[function(require,module,exports){
+},{"./isNativeReflectConstruct.js":20,"./setPrototypeOf.js":27}],13:[function(require,module,exports){
var toPropertyKey = require("./toPropertyKey.js");
function _defineProperties(target, props) {
for (var i = 0; i < props.length; i++) {
@@ -126,7 +139,7 @@ function _createClass(Constructor, protoProps, staticProps) {
return Constructor;
}
module.exports = _createClass, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./toPropertyKey.js":30}],12:[function(require,module,exports){
+},{"./toPropertyKey.js":32}],14:[function(require,module,exports){
var toPropertyKey = require("./toPropertyKey.js");
function _defineProperty(obj, key, value) {
key = toPropertyKey(key);
@@ -143,7 +156,7 @@ function _defineProperty(obj, key, value) {
return obj;
}
module.exports = _defineProperty, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./toPropertyKey.js":30}],13:[function(require,module,exports){
+},{"./toPropertyKey.js":32}],15:[function(require,module,exports){
var superPropBase = require("./superPropBase.js");
function _get() {
if (typeof Reflect !== "undefined" && Reflect.get) {
@@ -162,7 +175,7 @@ function _get() {
return _get.apply(this, arguments);
}
module.exports = _get, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./superPropBase.js":27}],14:[function(require,module,exports){
+},{"./superPropBase.js":29}],16:[function(require,module,exports){
function _getPrototypeOf(o) {
module.exports = _getPrototypeOf = Object.setPrototypeOf ? Object.getPrototypeOf.bind() : function _getPrototypeOf(o) {
return o.__proto__ || Object.getPrototypeOf(o);
@@ -170,7 +183,7 @@ function _getPrototypeOf(o) {
return _getPrototypeOf(o);
}
module.exports = _getPrototypeOf, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],15:[function(require,module,exports){
+},{}],17:[function(require,module,exports){
var setPrototypeOf = require("./setPrototypeOf.js");
function _inherits(subClass, superClass) {
if (typeof superClass !== "function" && superClass !== null) {
@@ -189,76 +202,77 @@ function _inherits(subClass, superClass) {
if (superClass) setPrototypeOf(subClass, superClass);
}
module.exports = _inherits, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./setPrototypeOf.js":25}],16:[function(require,module,exports){
+},{"./setPrototypeOf.js":27}],18:[function(require,module,exports){
function _interopRequireDefault(obj) {
return obj && obj.__esModule ? obj : {
"default": obj
};
}
module.exports = _interopRequireDefault, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],17:[function(require,module,exports){
+},{}],19:[function(require,module,exports){
function _isNativeFunction(fn) {
- return Function.toString.call(fn).indexOf("[native code]") !== -1;
-}
-module.exports = _isNativeFunction, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],18:[function(require,module,exports){
-function _isNativeReflectConstruct() {
- if (typeof Reflect === "undefined" || !Reflect.construct) return false;
- if (Reflect.construct.sham) return false;
- if (typeof Proxy === "function") return true;
try {
- Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {}));
- return true;
+ return Function.toString.call(fn).indexOf("[native code]") !== -1;
} catch (e) {
- return false;
+ return typeof fn === "function";
}
}
+module.exports = _isNativeFunction, module.exports.__esModule = true, module.exports["default"] = module.exports;
+},{}],20:[function(require,module,exports){
+function _isNativeReflectConstruct() {
+ try {
+ var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {}));
+ } catch (t) {}
+ return (module.exports = _isNativeReflectConstruct = function _isNativeReflectConstruct() {
+ return !!t;
+ }, module.exports.__esModule = true, module.exports["default"] = module.exports)();
+}
module.exports = _isNativeReflectConstruct, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],19:[function(require,module,exports){
+},{}],21:[function(require,module,exports){
function _iterableToArray(iter) {
if (typeof Symbol !== "undefined" && iter[Symbol.iterator] != null || iter["@@iterator"] != null) return Array.from(iter);
}
module.exports = _iterableToArray, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],20:[function(require,module,exports){
-function _iterableToArrayLimit(arr, i) {
- var _i = null == arr ? null : "undefined" != typeof Symbol && arr[Symbol.iterator] || arr["@@iterator"];
- if (null != _i) {
- var _s,
- _e,
- _x,
- _r,
- _arr = [],
- _n = !0,
- _d = !1;
+},{}],22:[function(require,module,exports){
+function _iterableToArrayLimit(r, l) {
+ var t = null == r ? null : "undefined" != typeof Symbol && r[Symbol.iterator] || r["@@iterator"];
+ if (null != t) {
+ var e,
+ n,
+ i,
+ u,
+ a = [],
+ f = !0,
+ o = !1;
try {
- if (_x = (_i = _i.call(arr)).next, 0 === i) {
- if (Object(_i) !== _i) return;
- _n = !1;
- } else for (; !(_n = (_s = _x.call(_i)).done) && (_arr.push(_s.value), _arr.length !== i); _n = !0);
- } catch (err) {
- _d = !0, _e = err;
+ if (i = (t = t.call(r)).next, 0 === l) {
+ if (Object(t) !== t) return;
+ f = !1;
+ } else for (; !(f = (e = i.call(t)).done) && (a.push(e.value), a.length !== l); f = !0);
+ } catch (r) {
+ o = !0, n = r;
} finally {
try {
- if (!_n && null != _i["return"] && (_r = _i["return"](), Object(_r) !== _r)) return;
+ if (!f && null != t["return"] && (u = t["return"](), Object(u) !== u)) return;
} finally {
- if (_d) throw _e;
+ if (o) throw n;
}
}
- return _arr;
+ return a;
}
}
module.exports = _iterableToArrayLimit, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],21:[function(require,module,exports){
+},{}],23:[function(require,module,exports){
function _nonIterableRest() {
throw new TypeError("Invalid attempt to destructure non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.");
}
module.exports = _nonIterableRest, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],22:[function(require,module,exports){
+},{}],24:[function(require,module,exports){
function _nonIterableSpread() {
throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.");
}
module.exports = _nonIterableSpread, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],23:[function(require,module,exports){
+},{}],25:[function(require,module,exports){
var _typeof = require("./typeof.js")["default"];
var assertThisInitialized = require("./assertThisInitialized.js");
function _possibleConstructorReturn(self, call) {
@@ -270,312 +284,312 @@ function _possibleConstructorReturn(self, call) {
return assertThisInitialized(self);
}
module.exports = _possibleConstructorReturn, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./assertThisInitialized.js":4,"./typeof.js":31}],24:[function(require,module,exports){
+},{"./assertThisInitialized.js":4,"./typeof.js":33}],26:[function(require,module,exports){
var _typeof = require("./typeof.js")["default"];
function _regeneratorRuntime() {
"use strict"; /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/facebook/regenerator/blob/main/LICENSE */
module.exports = _regeneratorRuntime = function _regeneratorRuntime() {
- return exports;
+ return e;
}, module.exports.__esModule = true, module.exports["default"] = module.exports;
- var exports = {},
- Op = Object.prototype,
- hasOwn = Op.hasOwnProperty,
- defineProperty = Object.defineProperty || function (obj, key, desc) {
- obj[key] = desc.value;
+ var t,
+ e = {},
+ r = Object.prototype,
+ n = r.hasOwnProperty,
+ o = Object.defineProperty || function (t, e, r) {
+ t[e] = r.value;
},
- $Symbol = "function" == typeof Symbol ? Symbol : {},
- iteratorSymbol = $Symbol.iterator || "@@iterator",
- asyncIteratorSymbol = $Symbol.asyncIterator || "@@asyncIterator",
- toStringTagSymbol = $Symbol.toStringTag || "@@toStringTag";
- function define(obj, key, value) {
- return Object.defineProperty(obj, key, {
- value: value,
+ i = "function" == typeof Symbol ? Symbol : {},
+ a = i.iterator || "@@iterator",
+ c = i.asyncIterator || "@@asyncIterator",
+ u = i.toStringTag || "@@toStringTag";
+ function define(t, e, r) {
+ return Object.defineProperty(t, e, {
+ value: r,
enumerable: !0,
configurable: !0,
writable: !0
- }), obj[key];
+ }), t[e];
}
try {
define({}, "");
- } catch (err) {
- define = function define(obj, key, value) {
- return obj[key] = value;
+ } catch (t) {
+ define = function define(t, e, r) {
+ return t[e] = r;
};
}
- function wrap(innerFn, outerFn, self, tryLocsList) {
- var protoGenerator = outerFn && outerFn.prototype instanceof Generator ? outerFn : Generator,
- generator = Object.create(protoGenerator.prototype),
- context = new Context(tryLocsList || []);
- return defineProperty(generator, "_invoke", {
- value: makeInvokeMethod(innerFn, self, context)
- }), generator;
+ function wrap(t, e, r, n) {
+ var i = e && e.prototype instanceof Generator ? e : Generator,
+ a = Object.create(i.prototype),
+ c = new Context(n || []);
+ return o(a, "_invoke", {
+ value: makeInvokeMethod(t, r, c)
+ }), a;
}
- function tryCatch(fn, obj, arg) {
+ function tryCatch(t, e, r) {
try {
return {
type: "normal",
- arg: fn.call(obj, arg)
+ arg: t.call(e, r)
};
- } catch (err) {
+ } catch (t) {
return {
type: "throw",
- arg: err
+ arg: t
};
}
}
- exports.wrap = wrap;
- var ContinueSentinel = {};
+ e.wrap = wrap;
+ var h = "suspendedStart",
+ l = "suspendedYield",
+ f = "executing",
+ s = "completed",
+ y = {};
function Generator() {}
function GeneratorFunction() {}
function GeneratorFunctionPrototype() {}
- var IteratorPrototype = {};
- define(IteratorPrototype, iteratorSymbol, function () {
+ var p = {};
+ define(p, a, function () {
return this;
});
- var getProto = Object.getPrototypeOf,
- NativeIteratorPrototype = getProto && getProto(getProto(values([])));
- NativeIteratorPrototype && NativeIteratorPrototype !== Op && hasOwn.call(NativeIteratorPrototype, iteratorSymbol) && (IteratorPrototype = NativeIteratorPrototype);
- var Gp = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(IteratorPrototype);
- function defineIteratorMethods(prototype) {
- ["next", "throw", "return"].forEach(function (method) {
- define(prototype, method, function (arg) {
- return this._invoke(method, arg);
+ var d = Object.getPrototypeOf,
+ v = d && d(d(values([])));
+ v && v !== r && n.call(v, a) && (p = v);
+ var g = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(p);
+ function defineIteratorMethods(t) {
+ ["next", "throw", "return"].forEach(function (e) {
+ define(t, e, function (t) {
+ return this._invoke(e, t);
});
});
}
- function AsyncIterator(generator, PromiseImpl) {
- function invoke(method, arg, resolve, reject) {
- var record = tryCatch(generator[method], generator, arg);
- if ("throw" !== record.type) {
- var result = record.arg,
- value = result.value;
- return value && "object" == _typeof(value) && hasOwn.call(value, "__await") ? PromiseImpl.resolve(value.__await).then(function (value) {
- invoke("next", value, resolve, reject);
- }, function (err) {
- invoke("throw", err, resolve, reject);
- }) : PromiseImpl.resolve(value).then(function (unwrapped) {
- result.value = unwrapped, resolve(result);
- }, function (error) {
- return invoke("throw", error, resolve, reject);
+ function AsyncIterator(t, e) {
+ function invoke(r, o, i, a) {
+ var c = tryCatch(t[r], t, o);
+ if ("throw" !== c.type) {
+ var u = c.arg,
+ h = u.value;
+ return h && "object" == _typeof(h) && n.call(h, "__await") ? e.resolve(h.__await).then(function (t) {
+ invoke("next", t, i, a);
+ }, function (t) {
+ invoke("throw", t, i, a);
+ }) : e.resolve(h).then(function (t) {
+ u.value = t, i(u);
+ }, function (t) {
+ return invoke("throw", t, i, a);
});
}
- reject(record.arg);
+ a(c.arg);
}
- var previousPromise;
- defineProperty(this, "_invoke", {
- value: function value(method, arg) {
+ var r;
+ o(this, "_invoke", {
+ value: function value(t, n) {
function callInvokeWithMethodAndArg() {
- return new PromiseImpl(function (resolve, reject) {
- invoke(method, arg, resolve, reject);
+ return new e(function (e, r) {
+ invoke(t, n, e, r);
});
}
- return previousPromise = previousPromise ? previousPromise.then(callInvokeWithMethodAndArg, callInvokeWithMethodAndArg) : callInvokeWithMethodAndArg();
+ return r = r ? r.then(callInvokeWithMethodAndArg, callInvokeWithMethodAndArg) : callInvokeWithMethodAndArg();
}
});
}
- function makeInvokeMethod(innerFn, self, context) {
- var state = "suspendedStart";
- return function (method, arg) {
- if ("executing" === state) throw new Error("Generator is already running");
- if ("completed" === state) {
- if ("throw" === method) throw arg;
- return doneResult();
+ function makeInvokeMethod(e, r, n) {
+ var o = h;
+ return function (i, a) {
+ if (o === f) throw new Error("Generator is already running");
+ if (o === s) {
+ if ("throw" === i) throw a;
+ return {
+ value: t,
+ done: !0
+ };
}
- for (context.method = method, context.arg = arg;;) {
- var delegate = context.delegate;
- if (delegate) {
- var delegateResult = maybeInvokeDelegate(delegate, context);
- if (delegateResult) {
- if (delegateResult === ContinueSentinel) continue;
- return delegateResult;
+ for (n.method = i, n.arg = a;;) {
+ var c = n.delegate;
+ if (c) {
+ var u = maybeInvokeDelegate(c, n);
+ if (u) {
+ if (u === y) continue;
+ return u;
}
}
- if ("next" === context.method) context.sent = context._sent = context.arg;else if ("throw" === context.method) {
- if ("suspendedStart" === state) throw state = "completed", context.arg;
- context.dispatchException(context.arg);
- } else "return" === context.method && context.abrupt("return", context.arg);
- state = "executing";
- var record = tryCatch(innerFn, self, context);
- if ("normal" === record.type) {
- if (state = context.done ? "completed" : "suspendedYield", record.arg === ContinueSentinel) continue;
+ if ("next" === n.method) n.sent = n._sent = n.arg;else if ("throw" === n.method) {
+ if (o === h) throw o = s, n.arg;
+ n.dispatchException(n.arg);
+ } else "return" === n.method && n.abrupt("return", n.arg);
+ o = f;
+ var p = tryCatch(e, r, n);
+ if ("normal" === p.type) {
+ if (o = n.done ? s : l, p.arg === y) continue;
return {
- value: record.arg,
- done: context.done
+ value: p.arg,
+ done: n.done
};
}
- "throw" === record.type && (state = "completed", context.method = "throw", context.arg = record.arg);
+ "throw" === p.type && (o = s, n.method = "throw", n.arg = p.arg);
}
};
}
- function maybeInvokeDelegate(delegate, context) {
- var methodName = context.method,
- method = delegate.iterator[methodName];
- if (undefined === method) return context.delegate = null, "throw" === methodName && delegate.iterator["return"] && (context.method = "return", context.arg = undefined, maybeInvokeDelegate(delegate, context), "throw" === context.method) || "return" !== methodName && (context.method = "throw", context.arg = new TypeError("The iterator does not provide a '" + methodName + "' method")), ContinueSentinel;
- var record = tryCatch(method, delegate.iterator, context.arg);
- if ("throw" === record.type) return context.method = "throw", context.arg = record.arg, context.delegate = null, ContinueSentinel;
- var info = record.arg;
- return info ? info.done ? (context[delegate.resultName] = info.value, context.next = delegate.nextLoc, "return" !== context.method && (context.method = "next", context.arg = undefined), context.delegate = null, ContinueSentinel) : info : (context.method = "throw", context.arg = new TypeError("iterator result is not an object"), context.delegate = null, ContinueSentinel);
+ function maybeInvokeDelegate(e, r) {
+ var n = r.method,
+ o = e.iterator[n];
+ if (o === t) return r.delegate = null, "throw" === n && e.iterator["return"] && (r.method = "return", r.arg = t, maybeInvokeDelegate(e, r), "throw" === r.method) || "return" !== n && (r.method = "throw", r.arg = new TypeError("The iterator does not provide a '" + n + "' method")), y;
+ var i = tryCatch(o, e.iterator, r.arg);
+ if ("throw" === i.type) return r.method = "throw", r.arg = i.arg, r.delegate = null, y;
+ var a = i.arg;
+ return a ? a.done ? (r[e.resultName] = a.value, r.next = e.nextLoc, "return" !== r.method && (r.method = "next", r.arg = t), r.delegate = null, y) : a : (r.method = "throw", r.arg = new TypeError("iterator result is not an object"), r.delegate = null, y);
}
- function pushTryEntry(locs) {
- var entry = {
- tryLoc: locs[0]
+ function pushTryEntry(t) {
+ var e = {
+ tryLoc: t[0]
};
- 1 in locs && (entry.catchLoc = locs[1]), 2 in locs && (entry.finallyLoc = locs[2], entry.afterLoc = locs[3]), this.tryEntries.push(entry);
+ 1 in t && (e.catchLoc = t[1]), 2 in t && (e.finallyLoc = t[2], e.afterLoc = t[3]), this.tryEntries.push(e);
}
- function resetTryEntry(entry) {
- var record = entry.completion || {};
- record.type = "normal", delete record.arg, entry.completion = record;
+ function resetTryEntry(t) {
+ var e = t.completion || {};
+ e.type = "normal", delete e.arg, t.completion = e;
}
- function Context(tryLocsList) {
+ function Context(t) {
this.tryEntries = [{
tryLoc: "root"
- }], tryLocsList.forEach(pushTryEntry, this), this.reset(!0);
+ }], t.forEach(pushTryEntry, this), this.reset(!0);
}
- function values(iterable) {
- if (iterable) {
- var iteratorMethod = iterable[iteratorSymbol];
- if (iteratorMethod) return iteratorMethod.call(iterable);
- if ("function" == typeof iterable.next) return iterable;
- if (!isNaN(iterable.length)) {
- var i = -1,
- next = function next() {
- for (; ++i < iterable.length;) if (hasOwn.call(iterable, i)) return next.value = iterable[i], next.done = !1, next;
- return next.value = undefined, next.done = !0, next;
+ function values(e) {
+ if (e || "" === e) {
+ var r = e[a];
+ if (r) return r.call(e);
+ if ("function" == typeof e.next) return e;
+ if (!isNaN(e.length)) {
+ var o = -1,
+ i = function next() {
+ for (; ++o < e.length;) if (n.call(e, o)) return next.value = e[o], next.done = !1, next;
+ return next.value = t, next.done = !0, next;
};
- return next.next = next;
+ return i.next = i;
}
}
- return {
- next: doneResult
- };
+ throw new TypeError(_typeof(e) + " is not iterable");
}
- function doneResult() {
- return {
- value: undefined,
- done: !0
- };
- }
- return GeneratorFunction.prototype = GeneratorFunctionPrototype, defineProperty(Gp, "constructor", {
+ return GeneratorFunction.prototype = GeneratorFunctionPrototype, o(g, "constructor", {
value: GeneratorFunctionPrototype,
configurable: !0
- }), defineProperty(GeneratorFunctionPrototype, "constructor", {
+ }), o(GeneratorFunctionPrototype, "constructor", {
value: GeneratorFunction,
configurable: !0
- }), GeneratorFunction.displayName = define(GeneratorFunctionPrototype, toStringTagSymbol, "GeneratorFunction"), exports.isGeneratorFunction = function (genFun) {
- var ctor = "function" == typeof genFun && genFun.constructor;
- return !!ctor && (ctor === GeneratorFunction || "GeneratorFunction" === (ctor.displayName || ctor.name));
- }, exports.mark = function (genFun) {
- return Object.setPrototypeOf ? Object.setPrototypeOf(genFun, GeneratorFunctionPrototype) : (genFun.__proto__ = GeneratorFunctionPrototype, define(genFun, toStringTagSymbol, "GeneratorFunction")), genFun.prototype = Object.create(Gp), genFun;
- }, exports.awrap = function (arg) {
+ }), GeneratorFunction.displayName = define(GeneratorFunctionPrototype, u, "GeneratorFunction"), e.isGeneratorFunction = function (t) {
+ var e = "function" == typeof t && t.constructor;
+ return !!e && (e === GeneratorFunction || "GeneratorFunction" === (e.displayName || e.name));
+ }, e.mark = function (t) {
+ return Object.setPrototypeOf ? Object.setPrototypeOf(t, GeneratorFunctionPrototype) : (t.__proto__ = GeneratorFunctionPrototype, define(t, u, "GeneratorFunction")), t.prototype = Object.create(g), t;
+ }, e.awrap = function (t) {
return {
- __await: arg
+ __await: t
};
- }, defineIteratorMethods(AsyncIterator.prototype), define(AsyncIterator.prototype, asyncIteratorSymbol, function () {
+ }, defineIteratorMethods(AsyncIterator.prototype), define(AsyncIterator.prototype, c, function () {
return this;
- }), exports.AsyncIterator = AsyncIterator, exports.async = function (innerFn, outerFn, self, tryLocsList, PromiseImpl) {
- void 0 === PromiseImpl && (PromiseImpl = Promise);
- var iter = new AsyncIterator(wrap(innerFn, outerFn, self, tryLocsList), PromiseImpl);
- return exports.isGeneratorFunction(outerFn) ? iter : iter.next().then(function (result) {
- return result.done ? result.value : iter.next();
+ }), e.AsyncIterator = AsyncIterator, e.async = function (t, r, n, o, i) {
+ void 0 === i && (i = Promise);
+ var a = new AsyncIterator(wrap(t, r, n, o), i);
+ return e.isGeneratorFunction(r) ? a : a.next().then(function (t) {
+ return t.done ? t.value : a.next();
});
- }, defineIteratorMethods(Gp), define(Gp, toStringTagSymbol, "Generator"), define(Gp, iteratorSymbol, function () {
+ }, defineIteratorMethods(g), define(g, u, "Generator"), define(g, a, function () {
return this;
- }), define(Gp, "toString", function () {
+ }), define(g, "toString", function () {
return "[object Generator]";
- }), exports.keys = function (val) {
- var object = Object(val),
- keys = [];
- for (var key in object) keys.push(key);
- return keys.reverse(), function next() {
- for (; keys.length;) {
- var key = keys.pop();
- if (key in object) return next.value = key, next.done = !1, next;
+ }), e.keys = function (t) {
+ var e = Object(t),
+ r = [];
+ for (var n in e) r.push(n);
+ return r.reverse(), function next() {
+ for (; r.length;) {
+ var t = r.pop();
+ if (t in e) return next.value = t, next.done = !1, next;
}
return next.done = !0, next;
};
- }, exports.values = values, Context.prototype = {
+ }, e.values = values, Context.prototype = {
constructor: Context,
- reset: function reset(skipTempReset) {
- if (this.prev = 0, this.next = 0, this.sent = this._sent = undefined, this.done = !1, this.delegate = null, this.method = "next", this.arg = undefined, this.tryEntries.forEach(resetTryEntry), !skipTempReset) for (var name in this) "t" === name.charAt(0) && hasOwn.call(this, name) && !isNaN(+name.slice(1)) && (this[name] = undefined);
+ reset: function reset(e) {
+ if (this.prev = 0, this.next = 0, this.sent = this._sent = t, this.done = !1, this.delegate = null, this.method = "next", this.arg = t, this.tryEntries.forEach(resetTryEntry), !e) for (var r in this) "t" === r.charAt(0) && n.call(this, r) && !isNaN(+r.slice(1)) && (this[r] = t);
},
stop: function stop() {
this.done = !0;
- var rootRecord = this.tryEntries[0].completion;
- if ("throw" === rootRecord.type) throw rootRecord.arg;
+ var t = this.tryEntries[0].completion;
+ if ("throw" === t.type) throw t.arg;
return this.rval;
},
- dispatchException: function dispatchException(exception) {
- if (this.done) throw exception;
- var context = this;
- function handle(loc, caught) {
- return record.type = "throw", record.arg = exception, context.next = loc, caught && (context.method = "next", context.arg = undefined), !!caught;
+ dispatchException: function dispatchException(e) {
+ if (this.done) throw e;
+ var r = this;
+ function handle(n, o) {
+ return a.type = "throw", a.arg = e, r.next = n, o && (r.method = "next", r.arg = t), !!o;
}
- for (var i = this.tryEntries.length - 1; i >= 0; --i) {
- var entry = this.tryEntries[i],
- record = entry.completion;
- if ("root" === entry.tryLoc) return handle("end");
- if (entry.tryLoc <= this.prev) {
- var hasCatch = hasOwn.call(entry, "catchLoc"),
- hasFinally = hasOwn.call(entry, "finallyLoc");
- if (hasCatch && hasFinally) {
- if (this.prev < entry.catchLoc) return handle(entry.catchLoc, !0);
- if (this.prev < entry.finallyLoc) return handle(entry.finallyLoc);
- } else if (hasCatch) {
- if (this.prev < entry.catchLoc) return handle(entry.catchLoc, !0);
+ for (var o = this.tryEntries.length - 1; o >= 0; --o) {
+ var i = this.tryEntries[o],
+ a = i.completion;
+ if ("root" === i.tryLoc) return handle("end");
+ if (i.tryLoc <= this.prev) {
+ var c = n.call(i, "catchLoc"),
+ u = n.call(i, "finallyLoc");
+ if (c && u) {
+ if (this.prev < i.catchLoc) return handle(i.catchLoc, !0);
+ if (this.prev < i.finallyLoc) return handle(i.finallyLoc);
+ } else if (c) {
+ if (this.prev < i.catchLoc) return handle(i.catchLoc, !0);
} else {
- if (!hasFinally) throw new Error("try statement without catch or finally");
- if (this.prev < entry.finallyLoc) return handle(entry.finallyLoc);
+ if (!u) throw new Error("try statement without catch or finally");
+ if (this.prev < i.finallyLoc) return handle(i.finallyLoc);
}
}
}
},
- abrupt: function abrupt(type, arg) {
- for (var i = this.tryEntries.length - 1; i >= 0; --i) {
- var entry = this.tryEntries[i];
- if (entry.tryLoc <= this.prev && hasOwn.call(entry, "finallyLoc") && this.prev < entry.finallyLoc) {
- var finallyEntry = entry;
+ abrupt: function abrupt(t, e) {
+ for (var r = this.tryEntries.length - 1; r >= 0; --r) {
+ var o = this.tryEntries[r];
+ if (o.tryLoc <= this.prev && n.call(o, "finallyLoc") && this.prev < o.finallyLoc) {
+ var i = o;
break;
}
}
- finallyEntry && ("break" === type || "continue" === type) && finallyEntry.tryLoc <= arg && arg <= finallyEntry.finallyLoc && (finallyEntry = null);
- var record = finallyEntry ? finallyEntry.completion : {};
- return record.type = type, record.arg = arg, finallyEntry ? (this.method = "next", this.next = finallyEntry.finallyLoc, ContinueSentinel) : this.complete(record);
+ i && ("break" === t || "continue" === t) && i.tryLoc <= e && e <= i.finallyLoc && (i = null);
+ var a = i ? i.completion : {};
+ return a.type = t, a.arg = e, i ? (this.method = "next", this.next = i.finallyLoc, y) : this.complete(a);
},
- complete: function complete(record, afterLoc) {
- if ("throw" === record.type) throw record.arg;
- return "break" === record.type || "continue" === record.type ? this.next = record.arg : "return" === record.type ? (this.rval = this.arg = record.arg, this.method = "return", this.next = "end") : "normal" === record.type && afterLoc && (this.next = afterLoc), ContinueSentinel;
+ complete: function complete(t, e) {
+ if ("throw" === t.type) throw t.arg;
+ return "break" === t.type || "continue" === t.type ? this.next = t.arg : "return" === t.type ? (this.rval = this.arg = t.arg, this.method = "return", this.next = "end") : "normal" === t.type && e && (this.next = e), y;
},
- finish: function finish(finallyLoc) {
- for (var i = this.tryEntries.length - 1; i >= 0; --i) {
- var entry = this.tryEntries[i];
- if (entry.finallyLoc === finallyLoc) return this.complete(entry.completion, entry.afterLoc), resetTryEntry(entry), ContinueSentinel;
+ finish: function finish(t) {
+ for (var e = this.tryEntries.length - 1; e >= 0; --e) {
+ var r = this.tryEntries[e];
+ if (r.finallyLoc === t) return this.complete(r.completion, r.afterLoc), resetTryEntry(r), y;
}
},
- "catch": function _catch(tryLoc) {
- for (var i = this.tryEntries.length - 1; i >= 0; --i) {
- var entry = this.tryEntries[i];
- if (entry.tryLoc === tryLoc) {
- var record = entry.completion;
- if ("throw" === record.type) {
- var thrown = record.arg;
- resetTryEntry(entry);
+ "catch": function _catch(t) {
+ for (var e = this.tryEntries.length - 1; e >= 0; --e) {
+ var r = this.tryEntries[e];
+ if (r.tryLoc === t) {
+ var n = r.completion;
+ if ("throw" === n.type) {
+ var o = n.arg;
+ resetTryEntry(r);
}
- return thrown;
+ return o;
}
}
throw new Error("illegal catch attempt");
},
- delegateYield: function delegateYield(iterable, resultName, nextLoc) {
+ delegateYield: function delegateYield(e, r, n) {
return this.delegate = {
- iterator: values(iterable),
- resultName: resultName,
- nextLoc: nextLoc
- }, "next" === this.method && (this.arg = undefined), ContinueSentinel;
+ iterator: values(e),
+ resultName: r,
+ nextLoc: n
+ }, "next" === this.method && (this.arg = t), y;
}
- }, exports;
+ }, e;
}
module.exports = _regeneratorRuntime, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./typeof.js":31}],25:[function(require,module,exports){
+},{"./typeof.js":33}],27:[function(require,module,exports){
function _setPrototypeOf(o, p) {
module.exports = _setPrototypeOf = Object.setPrototypeOf ? Object.setPrototypeOf.bind() : function _setPrototypeOf(o, p) {
o.__proto__ = p;
@@ -584,7 +598,7 @@ function _setPrototypeOf(o, p) {
return _setPrototypeOf(o, p);
}
module.exports = _setPrototypeOf, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],26:[function(require,module,exports){
+},{}],28:[function(require,module,exports){
var arrayWithHoles = require("./arrayWithHoles.js");
var iterableToArrayLimit = require("./iterableToArrayLimit.js");
var unsupportedIterableToArray = require("./unsupportedIterableToArray.js");
@@ -593,7 +607,7 @@ function _slicedToArray(arr, i) {
return arrayWithHoles(arr) || iterableToArrayLimit(arr, i) || unsupportedIterableToArray(arr, i) || nonIterableRest();
}
module.exports = _slicedToArray, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./arrayWithHoles.js":2,"./iterableToArrayLimit.js":20,"./nonIterableRest.js":21,"./unsupportedIterableToArray.js":32}],27:[function(require,module,exports){
+},{"./arrayWithHoles.js":2,"./iterableToArrayLimit.js":22,"./nonIterableRest.js":23,"./unsupportedIterableToArray.js":34}],29:[function(require,module,exports){
var getPrototypeOf = require("./getPrototypeOf.js");
function _superPropBase(object, property) {
while (!Object.prototype.hasOwnProperty.call(object, property)) {
@@ -603,7 +617,7 @@ function _superPropBase(object, property) {
return object;
}
module.exports = _superPropBase, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./getPrototypeOf.js":14}],28:[function(require,module,exports){
+},{"./getPrototypeOf.js":16}],30:[function(require,module,exports){
var arrayWithoutHoles = require("./arrayWithoutHoles.js");
var iterableToArray = require("./iterableToArray.js");
var unsupportedIterableToArray = require("./unsupportedIterableToArray.js");
@@ -612,39 +626,39 @@ function _toConsumableArray(arr) {
return arrayWithoutHoles(arr) || iterableToArray(arr) || unsupportedIterableToArray(arr) || nonIterableSpread();
}
module.exports = _toConsumableArray, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./arrayWithoutHoles.js":3,"./iterableToArray.js":19,"./nonIterableSpread.js":22,"./unsupportedIterableToArray.js":32}],29:[function(require,module,exports){
+},{"./arrayWithoutHoles.js":3,"./iterableToArray.js":21,"./nonIterableSpread.js":24,"./unsupportedIterableToArray.js":34}],31:[function(require,module,exports){
var _typeof = require("./typeof.js")["default"];
-function _toPrimitive(input, hint) {
- if (_typeof(input) !== "object" || input === null) return input;
- var prim = input[Symbol.toPrimitive];
- if (prim !== undefined) {
- var res = prim.call(input, hint || "default");
- if (_typeof(res) !== "object") return res;
+function toPrimitive(t, r) {
+ if ("object" != _typeof(t) || !t) return t;
+ var e = t[Symbol.toPrimitive];
+ if (void 0 !== e) {
+ var i = e.call(t, r || "default");
+ if ("object" != _typeof(i)) return i;
throw new TypeError("@@toPrimitive must return a primitive value.");
}
- return (hint === "string" ? String : Number)(input);
+ return ("string" === r ? String : Number)(t);
}
-module.exports = _toPrimitive, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./typeof.js":31}],30:[function(require,module,exports){
+module.exports = toPrimitive, module.exports.__esModule = true, module.exports["default"] = module.exports;
+},{"./typeof.js":33}],32:[function(require,module,exports){
var _typeof = require("./typeof.js")["default"];
var toPrimitive = require("./toPrimitive.js");
-function _toPropertyKey(arg) {
- var key = toPrimitive(arg, "string");
- return _typeof(key) === "symbol" ? key : String(key);
+function toPropertyKey(t) {
+ var i = toPrimitive(t, "string");
+ return "symbol" == _typeof(i) ? i : String(i);
}
-module.exports = _toPropertyKey, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./toPrimitive.js":29,"./typeof.js":31}],31:[function(require,module,exports){
-function _typeof(obj) {
+module.exports = toPropertyKey, module.exports.__esModule = true, module.exports["default"] = module.exports;
+},{"./toPrimitive.js":31,"./typeof.js":33}],33:[function(require,module,exports){
+function _typeof(o) {
"@babel/helpers - typeof";
- return (module.exports = _typeof = "function" == typeof Symbol && "symbol" == typeof Symbol.iterator ? function (obj) {
- return typeof obj;
- } : function (obj) {
- return obj && "function" == typeof Symbol && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj;
- }, module.exports.__esModule = true, module.exports["default"] = module.exports), _typeof(obj);
+ return (module.exports = _typeof = "function" == typeof Symbol && "symbol" == typeof Symbol.iterator ? function (o) {
+ return typeof o;
+ } : function (o) {
+ return o && "function" == typeof Symbol && o.constructor === Symbol && o !== Symbol.prototype ? "symbol" : typeof o;
+ }, module.exports.__esModule = true, module.exports["default"] = module.exports), _typeof(o);
}
module.exports = _typeof, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{}],32:[function(require,module,exports){
+},{}],34:[function(require,module,exports){
var arrayLikeToArray = require("./arrayLikeToArray.js");
function _unsupportedIterableToArray(o, minLen) {
if (!o) return;
@@ -655,7 +669,7 @@ function _unsupportedIterableToArray(o, minLen) {
if (n === "Arguments" || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) return arrayLikeToArray(o, minLen);
}
module.exports = _unsupportedIterableToArray, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./arrayLikeToArray.js":1}],33:[function(require,module,exports){
+},{"./arrayLikeToArray.js":1}],35:[function(require,module,exports){
var getPrototypeOf = require("./getPrototypeOf.js");
var setPrototypeOf = require("./setPrototypeOf.js");
var isNativeFunction = require("./isNativeFunction.js");
@@ -687,7 +701,7 @@ function _wrapNativeSuper(Class) {
return _wrapNativeSuper(Class);
}
module.exports = _wrapNativeSuper, module.exports.__esModule = true, module.exports["default"] = module.exports;
-},{"./construct.js":10,"./getPrototypeOf.js":14,"./isNativeFunction.js":17,"./setPrototypeOf.js":25}],34:[function(require,module,exports){
+},{"./construct.js":12,"./getPrototypeOf.js":16,"./isNativeFunction.js":19,"./setPrototypeOf.js":27}],36:[function(require,module,exports){
// TODO(Babel 8): Remove this file.
var runtime = require("../helpers/regeneratorRuntime")();
@@ -704,9 +718,9 @@ try {
}
}
-},{"../helpers/regeneratorRuntime":24}],35:[function(require,module,exports){
+},{"../helpers/regeneratorRuntime":26}],37:[function(require,module,exports){
-},{}],36:[function(require,module,exports){
+},{}],38:[function(require,module,exports){
'use strict';
module.exports = function () {
@@ -716,7 +730,7 @@ module.exports = function () {
);
};
-},{}],37:[function(require,module,exports){
+},{}],39:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -738,59 +752,43 @@ module.exports = function () {
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
* SOFTWARE.
*/
-
/**
* Created by Ahmed Zamil on 25/07/2017.
*/
+
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
-var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
-
var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime/helpers/possibleConstructorReturn"));
-
var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime/helpers/getPrototypeOf"));
-
+var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
var _AsyncReply2 = _interopRequireDefault(require("./AsyncReply.js"));
-
-function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = (0, _getPrototypeOf2["default"])(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2["default"])(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2["default"])(this, result); }; }
-
-function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }
-
-var AsyncBag = /*#__PURE__*/function (_AsyncReply) {
+function _callSuper(t, o, e) { return o = (0, _getPrototypeOf2["default"])(o), (0, _possibleConstructorReturn2["default"])(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], (0, _getPrototypeOf2["default"])(t).constructor) : o.apply(t, e)); }
+function _isNativeReflectConstruct() { try { var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); } catch (t) {} return (_isNativeReflectConstruct = function _isNativeReflectConstruct() { return !!t; })(); }
+var AsyncBag = exports["default"] = /*#__PURE__*/function (_AsyncReply) {
(0, _inherits2["default"])(AsyncBag, _AsyncReply);
-
- var _super = _createSuper(AsyncBag);
-
function AsyncBag() {
var _this;
-
(0, _classCallCheck2["default"])(this, AsyncBag);
- _this = _super.call(this);
+ _this = _callSuper(this, AsyncBag);
_this.replies = [];
_this.results = [];
_this.count = 0;
_this.sealedBag = false;
return _this;
}
-
(0, _createClass2["default"])(AsyncBag, [{
key: "seal",
value: function seal() {
this.sealedBag = true;
if (this.results.length == 0) this.trigger([]);
var self = this;
-
var singleTaskCompleted = function singleTaskCompleted(taskIndex) {
return function (results, reply) {
self.results[taskIndex] = results;
@@ -798,10 +796,8 @@ var AsyncBag = /*#__PURE__*/function (_AsyncReply) {
if (self.count == self.results.length) self.trigger(self.results);
};
};
+ for (var i = 0; i < this.results.length; i++) this.replies[i].then(singleTaskCompleted(i));
- for (var i = 0; i < this.results.length; i++) {
- this.replies[i].then(singleTaskCompleted(i));
- }
/*
this.replies[i].then(function(r, reply){
self.results[self.replies.indexOf(reply)] = r;
@@ -810,7 +806,6 @@ var AsyncBag = /*#__PURE__*/function (_AsyncReply) {
self.trigger(self.results);
});
*/
-
}
}, {
key: "add",
@@ -824,9 +819,7 @@ var AsyncBag = /*#__PURE__*/function (_AsyncReply) {
return AsyncBag;
}(_AsyncReply2["default"]);
-exports["default"] = AsyncBag;
-
-},{"./AsyncReply.js":40,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/getPrototypeOf":14,"@babel/runtime/helpers/inherits":15,"@babel/runtime/helpers/interopRequireDefault":16,"@babel/runtime/helpers/possibleConstructorReturn":23}],38:[function(require,module,exports){
+},{"./AsyncReply.js":42,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/getPrototypeOf":16,"@babel/runtime/helpers/inherits":17,"@babel/runtime/helpers/interopRequireDefault":18,"@babel/runtime/helpers/possibleConstructorReturn":25}],40:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -848,48 +841,31 @@ exports["default"] = AsyncBag;
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
* SOFTWARE.
*/
-
/**
* Created by Ahmed Zamil on 18/11/2017.
*/
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
-var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
-
var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime/helpers/possibleConstructorReturn"));
-
var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime/helpers/getPrototypeOf"));
-
+var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
var _wrapNativeSuper2 = _interopRequireDefault(require("@babel/runtime/helpers/wrapNativeSuper"));
-
var _ExceptionCode = _interopRequireDefault(require("./ExceptionCode.js"));
-
-function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = (0, _getPrototypeOf2["default"])(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2["default"])(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2["default"])(this, result); }; }
-
-function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }
-
-var AsyncException = /*#__PURE__*/function (_Error) {
+function _callSuper(t, o, e) { return o = (0, _getPrototypeOf2["default"])(o), (0, _possibleConstructorReturn2["default"])(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], (0, _getPrototypeOf2["default"])(t).constructor) : o.apply(t, e)); }
+function _isNativeReflectConstruct() { try { var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); } catch (t) {} return (_isNativeReflectConstruct = function _isNativeReflectConstruct() { return !!t; })(); }
+var AsyncException = exports["default"] = /*#__PURE__*/function (_Error) {
(0, _inherits2["default"])(AsyncException, _Error);
-
- var _super = _createSuper(AsyncException);
-
function AsyncException(type, code, message) {
var _this;
-
(0, _classCallCheck2["default"])(this, AsyncException);
- _this = _super.call(this);
-
+ _this = _callSuper(this, AsyncException);
if (type instanceof AsyncException) {
_this.raise(type.type, type.code, type.message);
} else if (type instanceof Error) {
@@ -899,25 +875,19 @@ var AsyncException = /*#__PURE__*/function (_Error) {
} else {
_this.raised = false;
}
-
return _this;
}
-
(0, _createClass2["default"])(AsyncException, [{
key: "raise",
value: function raise(type, code, message) {
this.type = type;
this.code = code;
-
if (type == 0 && message == null) {
- for (var i in _ExceptionCode["default"]) {
- if (_ExceptionCode["default"][i] == code) {
- this.message = i;
- break;
- }
+ for (var i in _ExceptionCode["default"]) if (_ExceptionCode["default"][i] == code) {
+ this.message = i;
+ break;
}
} else this.message = message;
-
this.raised = true;
}
}, {
@@ -929,9 +899,7 @@ var AsyncException = /*#__PURE__*/function (_Error) {
return AsyncException;
}( /*#__PURE__*/(0, _wrapNativeSuper2["default"])(Error));
-exports["default"] = AsyncException;
-
-},{"./ExceptionCode.js":42,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/getPrototypeOf":14,"@babel/runtime/helpers/inherits":15,"@babel/runtime/helpers/interopRequireDefault":16,"@babel/runtime/helpers/possibleConstructorReturn":23,"@babel/runtime/helpers/wrapNativeSuper":33}],39:[function(require,module,exports){
+},{"./ExceptionCode.js":44,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/getPrototypeOf":16,"@babel/runtime/helpers/inherits":17,"@babel/runtime/helpers/interopRequireDefault":18,"@babel/runtime/helpers/possibleConstructorReturn":25,"@babel/runtime/helpers/wrapNativeSuper":35}],41:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -953,72 +921,51 @@ exports["default"] = AsyncException;
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
* SOFTWARE.
*/
-
/**
* Created by Ahmed Zamil on 25/07/2017.
*/
+
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
-var _assertThisInitialized2 = _interopRequireDefault(require("@babel/runtime/helpers/assertThisInitialized"));
-
-var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
-
var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime/helpers/possibleConstructorReturn"));
-
var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime/helpers/getPrototypeOf"));
-
+var _assertThisInitialized2 = _interopRequireDefault(require("@babel/runtime/helpers/assertThisInitialized"));
+var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
var _AsyncReply2 = _interopRequireDefault(require("./AsyncReply.js"));
-
-function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = (0, _getPrototypeOf2["default"])(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2["default"])(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2["default"])(this, result); }; }
-
-function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }
-
-var AsyncQueue = /*#__PURE__*/function (_AsyncReply) {
+function _callSuper(t, o, e) { return o = (0, _getPrototypeOf2["default"])(o), (0, _possibleConstructorReturn2["default"])(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], (0, _getPrototypeOf2["default"])(t).constructor) : o.apply(t, e)); }
+function _isNativeReflectConstruct() { try { var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); } catch (t) {} return (_isNativeReflectConstruct = function _isNativeReflectConstruct() { return !!t; })(); }
+var AsyncQueue = exports["default"] = /*#__PURE__*/function (_AsyncReply) {
(0, _inherits2["default"])(AsyncQueue, _AsyncReply);
-
- var _super = _createSuper(AsyncQueue);
-
function AsyncQueue() {
var _this;
-
(0, _classCallCheck2["default"])(this, AsyncQueue);
- _this = _super.call(this);
+ _this = _callSuper(this, AsyncQueue);
_this.list = [];
var self = (0, _assertThisInitialized2["default"])(_this);
-
_this.processQueue = function () {
- for (var i = 0; i < self.list.length; i++) {
- if (self.list[i].ready) {
- self.trigger(self.list[i].result);
- self.ready = false; //self.list.splice(i, 1);
-
- self.list.shift();
- i--;
- } else if (self.list[i].failed) {
- self.ready = false;
- self.list.shift();
- i--;
- console.log("AsyncQueue (Reply Failed)");
- } else break;
- }
-
+ for (var i = 0; i < self.list.length; i++) if (self.list[i].ready) {
+ self.trigger(self.list[i].result);
+ self.ready = false;
+ //self.list.splice(i, 1);
+ self.list.shift();
+ i--;
+ } else if (self.list[i].failed) {
+ self.ready = false;
+ self.list.shift();
+ i--;
+ console.log("AsyncQueue (Reply Failed)");
+ } else break;
self.ready = self.list.length == 0;
};
-
return _this;
}
-
(0, _createClass2["default"])(AsyncQueue, [{
key: "add",
value: function add(reply) {
@@ -1036,9 +983,7 @@ var AsyncQueue = /*#__PURE__*/function (_AsyncReply) {
return AsyncQueue;
}(_AsyncReply2["default"]);
-exports["default"] = AsyncQueue;
-
-},{"./AsyncReply.js":40,"@babel/runtime/helpers/assertThisInitialized":4,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/getPrototypeOf":14,"@babel/runtime/helpers/inherits":15,"@babel/runtime/helpers/interopRequireDefault":16,"@babel/runtime/helpers/possibleConstructorReturn":23}],40:[function(require,module,exports){
+},{"./AsyncReply.js":42,"@babel/runtime/helpers/assertThisInitialized":4,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/getPrototypeOf":16,"@babel/runtime/helpers/inherits":17,"@babel/runtime/helpers/interopRequireDefault":18,"@babel/runtime/helpers/possibleConstructorReturn":25}],42:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -1064,57 +1009,40 @@ exports["default"] = AsyncQueue;
/**
* Created by Ahmed Zamil on 25/07/2017.
*/
+
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
-var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
-
var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime/helpers/possibleConstructorReturn"));
-
var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime/helpers/getPrototypeOf"));
-
+var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
var _wrapNativeSuper2 = _interopRequireDefault(require("@babel/runtime/helpers/wrapNativeSuper"));
-
var _AsyncException = _interopRequireDefault(require("./AsyncException.js"));
-
var _ExceptionCode = _interopRequireDefault(require("./ExceptionCode.js"));
-
var _ErrorType = _interopRequireDefault(require("./ErrorType.js"));
-
-function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = (0, _getPrototypeOf2["default"])(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2["default"])(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2["default"])(this, result); }; }
-
-function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }
-
-var AsyncReply = /*#__PURE__*/function (_Promise) {
+function _callSuper(t, o, e) { return o = (0, _getPrototypeOf2["default"])(o), (0, _possibleConstructorReturn2["default"])(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], (0, _getPrototypeOf2["default"])(t).constructor) : o.apply(t, e)); }
+function _isNativeReflectConstruct() { try { var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); } catch (t) {} return (_isNativeReflectConstruct = function _isNativeReflectConstruct() { return !!t; })(); }
+var AsyncReply = exports["default"] = /*#__PURE__*/function (_Promise) {
(0, _inherits2["default"])(AsyncReply, _Promise);
-
- var _super = _createSuper(AsyncReply);
-
function AsyncReply(result) {
var _this;
-
(0, _classCallCheck2["default"])(this, AsyncReply);
-
if (result instanceof Function) {
- _this = _super.call(this, result);
+ _this = _callSuper(this, AsyncReply, [result]);
_this.awaiter = result;
- } else _this = _super.call(this, function () {});
-
+ } else _this = _callSuper(this, AsyncReply, [function () {}]);
_this.callbacks = [];
_this.errorCallbacks = [];
_this.progressCallbacks = [];
_this.chunkCallbacks = [];
_this.exception = new _AsyncException["default"](); // null;
+
//var self = this;
if (result !== undefined && !(result instanceof Function)) {
@@ -1124,10 +1052,8 @@ var AsyncReply = /*#__PURE__*/function (_Promise) {
_this.ready = false;
_this.result = null;
}
-
return (0, _possibleConstructorReturn2["default"])(_this);
}
-
(0, _createClass2["default"])(AsyncReply, [{
key: "then",
value: function then(callback, onError) {
@@ -1135,14 +1061,13 @@ var AsyncReply = /*#__PURE__*/function (_Promise) {
this.callbacks.push(callback);
if (this.ready) callback(this.result, this);
}
-
if (onError != undefined) {
this.error(onError);
}
-
return this;
- } // Alias for then()
+ }
+ // Alias for then()
}, {
key: "done",
value: function done(callback) {
@@ -1152,11 +1077,9 @@ var AsyncReply = /*#__PURE__*/function (_Promise) {
key: "error",
value: function error(callback) {
this.errorCallbacks.push(callback);
-
if (this.exception.raised) {
callback(this.exception);
}
-
return this;
}
}, {
@@ -1170,8 +1093,9 @@ var AsyncReply = /*#__PURE__*/function (_Promise) {
value: function chunk(callback) {
this.chunkCallbacks.push(callback);
return this;
- } // Alias for chunk()
+ }
+ // Alias for chunk()
}, {
key: "next",
value: function next(callback) {
@@ -1195,11 +1119,7 @@ var AsyncReply = /*#__PURE__*/function (_Promise) {
if (this.exception.raised) return this;
this.result = result;
this.ready = true;
-
- for (var i = 0; i < this.callbacks.length; i++) {
- this.callbacks[i](result, this);
- }
-
+ for (var i = 0; i < this.callbacks.length; i++) this.callbacks[i](result, this);
return this;
}
}, {
@@ -1207,56 +1127,46 @@ var AsyncReply = /*#__PURE__*/function (_Promise) {
value: function triggerError(type, code, message) {
if (this.ready) return this;
if (type instanceof _AsyncException["default"]) this.exception.raise(type.type, type.code, type.message);else this.exception.raise(type, code, message);
- if (this.errorCallbacks.length == 0) throw this.exception;else for (var i = 0; i < this.errorCallbacks.length; i++) {
- this.errorCallbacks[i](this.exception, this);
- }
+ if (this.errorCallbacks.length == 0) throw this.exception;else for (var i = 0; i < this.errorCallbacks.length; i++) this.errorCallbacks[i](this.exception, this);
return this;
}
}, {
key: "triggerProgress",
value: function triggerProgress(type, value, max) {
- for (var i = 0; i < this.progressCallbacks.length; i++) {
- this.progressCallbacks[i](type, value, max, this);
- }
-
+ for (var i = 0; i < this.progressCallbacks.length; i++) this.progressCallbacks[i](type, value, max, this);
return this;
}
}, {
key: "triggerChunk",
value: function triggerChunk(value) {
- for (var i = 0; i < this.chunkCallbacks.length; i++) {
- this.chunkCallbacks[i](value, this);
- }
-
+ for (var i = 0; i < this.chunkCallbacks.length; i++) this.chunkCallbacks[i](value, this);
return this;
}
}]);
return AsyncReply;
}( /*#__PURE__*/(0, _wrapNativeSuper2["default"])(Promise));
-exports["default"] = AsyncReply;
-
-},{"./AsyncException.js":38,"./ErrorType.js":41,"./ExceptionCode.js":42,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/getPrototypeOf":14,"@babel/runtime/helpers/inherits":15,"@babel/runtime/helpers/interopRequireDefault":16,"@babel/runtime/helpers/possibleConstructorReturn":23,"@babel/runtime/helpers/wrapNativeSuper":33}],41:[function(require,module,exports){
+},{"./AsyncException.js":40,"./ErrorType.js":43,"./ExceptionCode.js":44,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/getPrototypeOf":16,"@babel/runtime/helpers/inherits":17,"@babel/runtime/helpers/interopRequireDefault":18,"@babel/runtime/helpers/possibleConstructorReturn":25,"@babel/runtime/helpers/wrapNativeSuper":35}],43:[function(require,module,exports){
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-var _default = {
+var _default = exports["default"] = {
Management: 0,
Exception: 1
};
-exports["default"] = _default;
-},{}],42:[function(require,module,exports){
+},{}],44:[function(require,module,exports){
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-var _default = //const ExceptionCode =
+var _default = exports["default"] =
+//const ExceptionCode =
{
RuntimeException: 0,
HostNotReachable: 1,
@@ -1295,11 +1205,12 @@ var _default = //const ExceptionCode =
AlreadyUnlistened: 34,
NotListenable: 35,
ParseError: 36,
- Timeout: 37
+ Timeout: 37,
+ NotSupported: 38,
+ NotImplemented: 39
};
-exports["default"] = _default;
-},{}],43:[function(require,module,exports){
+},{}],45:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -1325,41 +1236,28 @@ exports["default"] = _default;
/**
* Created by Ahmed Zamil on 31/08/2017.
*/
+
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
-var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
-
var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime/helpers/possibleConstructorReturn"));
-
var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime/helpers/getPrototypeOf"));
-
+var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
var _IEventHandler2 = _interopRequireDefault(require("./IEventHandler.js"));
-
-function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = (0, _getPrototypeOf2["default"])(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2["default"])(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2["default"])(this, result); }; }
-
-function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }
-
-var IDestructible = /*#__PURE__*/function (_IEventHandler) {
+function _callSuper(t, o, e) { return o = (0, _getPrototypeOf2["default"])(o), (0, _possibleConstructorReturn2["default"])(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], (0, _getPrototypeOf2["default"])(t).constructor) : o.apply(t, e)); }
+function _isNativeReflectConstruct() { try { var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); } catch (t) {} return (_isNativeReflectConstruct = function _isNativeReflectConstruct() { return !!t; })(); }
+var IDestructible = exports["default"] = /*#__PURE__*/function (_IEventHandler) {
(0, _inherits2["default"])(IDestructible, _IEventHandler);
-
- var _super = _createSuper(IDestructible);
-
function IDestructible() {
(0, _classCallCheck2["default"])(this, IDestructible);
- return _super.call(this);
+ return _callSuper(this, IDestructible);
}
-
(0, _createClass2["default"])(IDestructible, [{
key: "destroy",
value: function destroy() {
@@ -1369,9 +1267,7 @@ var IDestructible = /*#__PURE__*/function (_IEventHandler) {
return IDestructible;
}(_IEventHandler2["default"]);
-exports["default"] = IDestructible;
-
-},{"./IEventHandler.js":44,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/getPrototypeOf":14,"@babel/runtime/helpers/inherits":15,"@babel/runtime/helpers/interopRequireDefault":16,"@babel/runtime/helpers/possibleConstructorReturn":23}],44:[function(require,module,exports){
+},{"./IEventHandler.js":46,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/getPrototypeOf":16,"@babel/runtime/helpers/inherits":17,"@babel/runtime/helpers/interopRequireDefault":18,"@babel/runtime/helpers/possibleConstructorReturn":25}],46:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -1400,22 +1296,17 @@ exports["default"] = IDestructible;
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
-var IEventHandler = /*#__PURE__*/function () {
+var IEventHandler = exports["default"] = /*#__PURE__*/function () {
function IEventHandler() {
(0, _classCallCheck2["default"])(this, IEventHandler);
this._events = {};
}
-
(0, _createClass2["default"])(IEventHandler, [{
key: "_register",
value: function _register(event) {
@@ -1426,48 +1317,40 @@ var IEventHandler = /*#__PURE__*/function () {
value: function _emit(event) {
event = event.toLowerCase();
var args = Array.prototype.slice.call(arguments, 1);
- if (this._events[event]) for (var i = 0; i < this._events[event].length; i++) {
- if (this._events[event][i].f.apply(this._events[event][i].i, args)) return true;
- }
+ if (this._events[event]) for (var i = 0; i < this._events[event].length; i++) if (this._events[event][i].f.apply(this._events[event][i].i, args)) return true;
return false;
}
}, {
key: "_emitArgs",
value: function _emitArgs(event, args) {
event = event.toLowerCase();
- if (this._events[event]) for (var i = 0; i < this._events[event].length; i++) {
- if (this._events[event][i].f.apply(this._events[event][i].i, args)) return true;
- }
+ if (this._events[event]) for (var i = 0; i < this._events[event].length; i++) if (this._events[event][i].f.apply(this._events[event][i].i, args)) return true;
return this;
}
}, {
key: "on",
value: function on(event, fn, issuer) {
if (!(fn instanceof Function)) return this;
- event = event.toLowerCase(); // add
-
+ event = event.toLowerCase();
+ // add
if (!this._events[event]) this._events[event] = [];
-
this._events[event].push({
f: fn,
i: issuer == null ? this : issuer
});
-
return this;
}
}, {
key: "off",
value: function off(event, fn) {
event = event.toLowerCase();
-
if (this._events[event]) {
if (fn) {
- for (var i = 0; i < this._events[event].length; i++) {
- if (this._events[event][i].f == fn) this._events[event].splice(i--, 1);
- } //var index = this._events[event].indexOf(fn);
+ for (var i = 0; i < this._events[event].length; i++) if (this._events[event][i].f == fn) this._events[event].splice(i--, 1);
+
+ //var index = this._events[event].indexOf(fn);
//if (index > -1)
//this._events[event].splice(index, 1);
-
} else {
this._events[event] = [];
}
@@ -1477,22 +1360,19 @@ var IEventHandler = /*#__PURE__*/function () {
return IEventHandler;
}();
-exports["default"] = IEventHandler;
-
-},{"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/interopRequireDefault":16}],45:[function(require,module,exports){
+},{"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/interopRequireDefault":18}],47:[function(require,module,exports){
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-var _default = {
+var _default = exports["default"] = {
Execution: 0,
Network: 1
};
-exports["default"] = _default;
-},{}],46:[function(require,module,exports){
+},{}],48:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -1518,67 +1398,46 @@ exports["default"] = _default;
/**
* Created by Ahmed Zamil on 05/09/2017.
*/
+
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
-var _assertThisInitialized2 = _interopRequireDefault(require("@babel/runtime/helpers/assertThisInitialized"));
-
-var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
-
var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime/helpers/possibleConstructorReturn"));
-
var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime/helpers/getPrototypeOf"));
-
+var _assertThisInitialized2 = _interopRequireDefault(require("@babel/runtime/helpers/assertThisInitialized"));
+var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
var _classPrivateFieldGet2 = _interopRequireDefault(require("@babel/runtime/helpers/classPrivateFieldGet"));
-
var _IEventHandler2 = _interopRequireDefault(require("../Core/IEventHandler.js"));
-
var _IDestructible = _interopRequireDefault(require("../Core/IDestructible.js"));
-
function _createForOfIteratorHelper(o, allowArrayLike) { var it = typeof Symbol !== "undefined" && o[Symbol.iterator] || o["@@iterator"]; if (!it) { if (Array.isArray(o) || (it = _unsupportedIterableToArray(o)) || allowArrayLike && o && typeof o.length === "number") { if (it) o = it; var i = 0; var F = function F() {}; return { s: F, n: function n() { if (i >= o.length) return { done: true }; return { done: false, value: o[i++] }; }, e: function e(_e) { throw _e; }, f: F }; } throw new TypeError("Invalid attempt to iterate non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method."); } var normalCompletion = true, didErr = false, err; return { s: function s() { it = it.call(o); }, n: function n() { var step = it.next(); normalCompletion = step.done; return step; }, e: function e(_e2) { didErr = true; err = _e2; }, f: function f() { try { if (!normalCompletion && it["return"] != null) it["return"](); } finally { if (didErr) throw err; } } }; }
-
function _unsupportedIterableToArray(o, minLen) { if (!o) return; if (typeof o === "string") return _arrayLikeToArray(o, minLen); var n = Object.prototype.toString.call(o).slice(8, -1); if (n === "Object" && o.constructor) n = o.constructor.name; if (n === "Map" || n === "Set") return Array.from(o); if (n === "Arguments" || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) return _arrayLikeToArray(o, minLen); }
-
-function _arrayLikeToArray(arr, len) { if (len == null || len > arr.length) len = arr.length; for (var i = 0, arr2 = new Array(len); i < len; i++) { arr2[i] = arr[i]; } return arr2; }
-
-function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = (0, _getPrototypeOf2["default"])(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2["default"])(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2["default"])(this, result); }; }
-
-function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }
-
+function _arrayLikeToArray(arr, len) { if (len == null || len > arr.length) len = arr.length; for (var i = 0, arr2 = new Array(len); i < len; i++) arr2[i] = arr[i]; return arr2; }
+function _callSuper(t, o, e) { return o = (0, _getPrototypeOf2["default"])(o), (0, _possibleConstructorReturn2["default"])(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], (0, _getPrototypeOf2["default"])(t).constructor) : o.apply(t, e)); }
+function _isNativeReflectConstruct() { try { var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); } catch (t) {} return (_isNativeReflectConstruct = function _isNativeReflectConstruct() { return !!t; })(); }
+function _classPrivateFieldInitSpec(obj, privateMap, value) { _checkPrivateRedeclaration(obj, privateMap); privateMap.set(obj, value); }
+function _checkPrivateRedeclaration(obj, privateCollection) { if (privateCollection.has(obj)) { throw new TypeError("Cannot initialize the same private elements twice on an object"); } }
var _item_destroyed = /*#__PURE__*/new WeakMap();
-
-var AutoList = /*#__PURE__*/function (_IEventHandler) {
+var AutoList = exports["default"] = /*#__PURE__*/function (_IEventHandler) {
(0, _inherits2["default"])(AutoList, _IEventHandler);
-
- var _super = _createSuper(AutoList);
-
function AutoList() {
var _this;
-
(0, _classCallCheck2["default"])(this, AutoList);
- _this = _super.call(this);
-
- _item_destroyed.set((0, _assertThisInitialized2["default"])(_this), {
+ _this = _callSuper(this, AutoList);
+ _classPrivateFieldInitSpec((0, _assertThisInitialized2["default"])(_this), _item_destroyed, {
writable: true,
value: function value(sender) {
this.remove(sender);
}
});
-
_this.list = [];
return _this;
}
-
(0, _createClass2["default"])(AutoList, [{
key: "length",
get: function get() {
@@ -1589,7 +1448,6 @@ var AutoList = /*#__PURE__*/function (_IEventHandler) {
value: function add(value) {
if (value instanceof _IDestructible["default"]) value.on("destroy", (0, _classPrivateFieldGet2["default"])(this, _item_destroyed), this);
this.list.push(value);
-
this._emit("add", value);
}
}, {
@@ -1614,8 +1472,7 @@ var AutoList = /*#__PURE__*/function (_IEventHandler) {
key: "first",
value: function first(selector) {
var _iterator = _createForOfIteratorHelper(this.list),
- _step;
-
+ _step;
try {
for (_iterator.s(); !(_step = _iterator.n()).done;) {
var el = _step.value;
@@ -1649,16 +1506,13 @@ var AutoList = /*#__PURE__*/function (_IEventHandler) {
var item = this.list[index];
if (item instanceof _IDestructible["default"]) item.off("destroy", (0, _classPrivateFieldGet2["default"])(this, _item_destroyed));
this.list.splice(index, 1);
-
this._emit("remove", item);
}
}]);
return AutoList;
}(_IEventHandler2["default"]);
-exports["default"] = AutoList;
-
-},{"../Core/IDestructible.js":43,"../Core/IEventHandler.js":44,"@babel/runtime/helpers/assertThisInitialized":4,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/classPrivateFieldGet":9,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/getPrototypeOf":14,"@babel/runtime/helpers/inherits":15,"@babel/runtime/helpers/interopRequireDefault":16,"@babel/runtime/helpers/possibleConstructorReturn":23}],47:[function(require,module,exports){
+},{"../Core/IDestructible.js":45,"../Core/IEventHandler.js":46,"@babel/runtime/helpers/assertThisInitialized":4,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/classPrivateFieldGet":10,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/getPrototypeOf":16,"@babel/runtime/helpers/inherits":17,"@babel/runtime/helpers/interopRequireDefault":18,"@babel/runtime/helpers/possibleConstructorReturn":25}],49:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -1684,67 +1538,48 @@ exports["default"] = AutoList;
/**
* Created by Ahmed Zamil on 05/09/2017.
*/
+
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
-var _assertThisInitialized2 = _interopRequireDefault(require("@babel/runtime/helpers/assertThisInitialized"));
-
-var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
-
var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime/helpers/possibleConstructorReturn"));
-
var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime/helpers/getPrototypeOf"));
-
+var _assertThisInitialized2 = _interopRequireDefault(require("@babel/runtime/helpers/assertThisInitialized"));
+var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
var _classPrivateFieldGet2 = _interopRequireDefault(require("@babel/runtime/helpers/classPrivateFieldGet"));
-
var _IEventHandler2 = _interopRequireDefault(require("../Core/IEventHandler.js"));
-
var _IDestructible = _interopRequireDefault(require("../Core/IDestructible.js"));
-
-function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = (0, _getPrototypeOf2["default"])(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2["default"])(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2["default"])(this, result); }; }
-
-function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }
-
+function _callSuper(t, o, e) { return o = (0, _getPrototypeOf2["default"])(o), (0, _possibleConstructorReturn2["default"])(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], (0, _getPrototypeOf2["default"])(t).constructor) : o.apply(t, e)); }
+function _isNativeReflectConstruct() { try { var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); } catch (t) {} return (_isNativeReflectConstruct = function _isNativeReflectConstruct() { return !!t; })(); }
+function _classPrivateFieldInitSpec(obj, privateMap, value) { _checkPrivateRedeclaration(obj, privateMap); privateMap.set(obj, value); }
+function _checkPrivateRedeclaration(obj, privateCollection) { if (privateCollection.has(obj)) { throw new TypeError("Cannot initialize the same private elements twice on an object"); } }
var _item_destroyed = /*#__PURE__*/new WeakMap();
-
-var AutoMap = /*#__PURE__*/function (_IEventHandler) {
+var AutoMap = exports["default"] = /*#__PURE__*/function (_IEventHandler) {
(0, _inherits2["default"])(AutoMap, _IEventHandler);
-
- var _super = _createSuper(AutoMap);
-
function AutoMap() {
var _this;
-
(0, _classCallCheck2["default"])(this, AutoMap);
- _this = _super.call(this);
-
- _item_destroyed.set((0, _assertThisInitialized2["default"])(_this), {
+ _this = _callSuper(this, AutoMap);
+ _classPrivateFieldInitSpec((0, _assertThisInitialized2["default"])(_this), _item_destroyed, {
writable: true,
value: function value(sender) {
this.remove(sender);
}
});
-
_this.dic = {};
return _this;
}
-
(0, _createClass2["default"])(AutoMap, [{
key: "add",
value: function add(key, value) {
if (value instanceof _IDestructible["default"]) value.on("destroy", (0, _classPrivateFieldGet2["default"])(this, _item_destroyed));
this.dic[key] = value;
-
this._emit("add", key, value);
}
}, {
@@ -1765,9 +1600,7 @@ var AutoMap = /*#__PURE__*/function (_IEventHandler) {
return AutoMap;
}(_IEventHandler2["default"]);
-exports["default"] = AutoMap;
-
-},{"../Core/IDestructible.js":43,"../Core/IEventHandler.js":44,"@babel/runtime/helpers/assertThisInitialized":4,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/classPrivateFieldGet":9,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/getPrototypeOf":14,"@babel/runtime/helpers/inherits":15,"@babel/runtime/helpers/interopRequireDefault":16,"@babel/runtime/helpers/possibleConstructorReturn":23}],48:[function(require,module,exports){
+},{"../Core/IDestructible.js":45,"../Core/IEventHandler.js":46,"@babel/runtime/helpers/assertThisInitialized":4,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/classPrivateFieldGet":10,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/getPrototypeOf":16,"@babel/runtime/helpers/inherits":17,"@babel/runtime/helpers/interopRequireDefault":18,"@babel/runtime/helpers/possibleConstructorReturn":25}],50:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -1793,27 +1626,23 @@ exports["default"] = AutoMap;
/**
* Created by Ahmed Zamil on 25/08/2017.
*/
+
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = void 0;
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
var _DC = _interopRequireDefault(require("./DC.js"));
-
-var BinaryList = /*#__PURE__*/function () {
+var BinaryList = exports["default"] = /*#__PURE__*/function () {
function BinaryList() {
(0, _classCallCheck2["default"])(this, BinaryList);
- this.list = []; //this.data = [];
+ this.list = [];
+ //this.data = [];
}
-
(0, _createClass2["default"])(BinaryList, [{
key: "addDateTime",
value: function addDateTime(value, endian) {
@@ -2051,9 +1880,7 @@ var BinaryList = /*#__PURE__*/function () {
return BinaryList;
}();
-exports["default"] = BinaryList;
-
-},{"./DC.js":50,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/interopRequireDefault":16}],49:[function(require,module,exports){
+},{"./DC.js":52,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/interopRequireDefault":18}],51:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -2079,103 +1906,68 @@ exports["default"] = BinaryList;
/**
* Created by Ahmed Zamil on 25/07/2017.
*/
+
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = exports.CodecParseResults = exports.CodecComposeResults = void 0;
-
-var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
var _defineProperty3 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
-
+var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _AsyncBag = _interopRequireDefault(require("../Core/AsyncBag.js"));
-
var _AsyncReply = _interopRequireDefault(require("../Core/AsyncReply.js"));
-
var _PropertyValue = _interopRequireDefault(require("./PropertyValue.js"));
-
var _DC = require("./DC.js");
-
var _BinaryList = _interopRequireDefault(require("./BinaryList.js"));
-
var _DistributedPropertyContext = _interopRequireDefault(require("../Net/IIP/DistributedPropertyContext.js"));
-
var _DistributedResource = _interopRequireDefault(require("../Net/IIP/DistributedResource.js"));
-
var _IResource = _interopRequireDefault(require("../Resource/IResource.js"));
-
var _IRecord = _interopRequireDefault(require("./IRecord.js"));
-
var _Record = _interopRequireDefault(require("./Record.js"));
-
var _ResourceArrayType = _interopRequireDefault(require("./ResourceArrayType.js"));
-
var _Warehouse = _interopRequireDefault(require("../Resource/Warehouse.js"));
-
var _TemplateType = _interopRequireDefault(require("../Resource/Template/TemplateType.js"));
-
var _NotModified = _interopRequireDefault(require("./NotModified.js"));
-
var _KeyList = _interopRequireDefault(require("./KeyList.js"));
-
var _DataSerializer = _interopRequireDefault(require("./DataSerializer.js"));
-
var _DataDeserializer = _interopRequireDefault(require("./DataDeserializer.js"));
-
var _TypedList = _interopRequireDefault(require("./TypedList.js"));
-
var _TypedMap = _interopRequireDefault(require("./TypedMap.js"));
-
var _IEnum = _interopRequireDefault(require("./IEnum.js"));
-
var _TransmissionType = require("./TransmissionType.js");
-
var _ExtendedTypes = require("./ExtendedTypes.js");
-
var _PropertyValueArray = _interopRequireDefault(require("./PropertyValueArray.js"));
-
var _RecordArray = _interopRequireDefault(require("./RecordArray.js"));
-
var _ResourceArray = _interopRequireDefault(require("./ResourceArray.js"));
-
var _Tuple = _interopRequireDefault(require("./Tuple.js"));
-
var _defineProperty2;
-
-var CodecComposeResults = //final int transmissionTypeIdentifier;
+var CodecComposeResults = exports.CodecComposeResults = /*#__PURE__*/(0, _createClass2["default"])(
+//final int transmissionTypeIdentifier;
//final DC data;
function CodecComposeResults(transmissionTypeIdentifier, data) {
(0, _classCallCheck2["default"])(this, CodecComposeResults);
this.transmissionTypeIdentifier = transmissionTypeIdentifier;
this.data = data;
-};
-
-exports.CodecComposeResults = CodecComposeResults;
-
-var CodecParseResults = //final AsyncReply reply;
+});
+var CodecParseResults = exports.CodecParseResults = /*#__PURE__*/(0, _createClass2["default"])(
+//final AsyncReply reply;
//final int size;
+
function CodecParseResults(size, reply) {
(0, _classCallCheck2["default"])(this, CodecParseResults);
this.size = size;
this.reply = reply;
-};
-
-exports.CodecParseResults = CodecParseResults;
-
-var Codec = /*#__PURE__*/function () {
+});
+var Codec = exports["default"] = /*#__PURE__*/function () {
function Codec() {
(0, _classCallCheck2["default"])(this, Codec);
}
-
(0, _createClass2["default"])(Codec, null, [{
key: "parse",
- value: //AsyncReply Parser(byte[] data, uint offset, uint length, DistributedConnection connection);
+ value:
///
/// Parse a value
///
@@ -2188,38 +1980,31 @@ var Codec = /*#__PURE__*/function () {
function parse(data, offset, connection, requestSequence) {
var dataType = arguments.length > 4 && arguments[4] !== undefined ? arguments[4] : null;
var len = 0;
-
if (dataType == null) {
var _dataType$offset, _dataType;
-
var parsedDataTyped = _TransmissionType.TransmissionType.parse(data, offset, data.length);
-
len = parsedDataTyped.size;
dataType = parsedDataTyped.type;
offset = (_dataType$offset = (_dataType = dataType) === null || _dataType === void 0 ? void 0 : _dataType.offset) !== null && _dataType$offset !== void 0 ? _dataType$offset : 0;
} else len = dataType.contentLength;
-
if (dataType != null) {
if (dataType.classType == _TransmissionType.TransmissionTypeClass.Fixed) {
return new CodecParseResults(len, Codec.fixedParsers[dataType.exponent][dataType.index](data, dataType.offset, dataType.contentLength, connection, requestSequence));
} else if (dataType.classType == _TransmissionType.TransmissionTypeClass.Dynamic) {
return new CodecParseResults(len, Codec.dynamicParsers[dataType.index](data, dataType.offset, dataType.contentLength, connection, requestSequence));
- } else //if (tt.Class == TransmissionTypeClass.Typed)
+ } else
+ //if (tt.Class == TransmissionTypeClass.Typed)
{
return new CodecParseResults(len, Codec.typedParsers[dataType.index](data, dataType.offset, dataType.contentLength, connection, requestSequence));
}
}
-
throw Error("Can't parse transmission type.");
}
}, {
key: "mapFromObject",
value: function mapFromObject(map) {
var rt = new Map();
-
- for (var i in map) {
- rt.set(i, map[i]);
- }
+ for (var i in map) rt.set(i, map[i]);
}
}, {
key: "getListType",
@@ -2230,20 +2015,24 @@ var Codec = /*#__PURE__*/function () {
key: "getMapTypes",
value: function getMapTypes(map) {
if (map instanceof _TypedMap["default"]) return _TypedMap["default"].getTypes(map);else return [Object, Object];
- } ///
+ }
+
+ ///
/// Compose a variable
///
/// Value to compose.
/// DistributedConnection is required to check locality.
/// If True, prepend the DataType at the beginning of the output.
/// Array of bytes in the network byte order.
-
}, {
key: "compose",
value: function compose(valueOrSource, connection) {
if (valueOrSource == null) return _TransmissionType.TransmissionType.compose(_TransmissionType.TransmissionTypeIdentifier.Null, new _DC.DC(0));
- var type = valueOrSource.constructor; // if (type.)
+ var type = valueOrSource.constructor;
+
+ // if (type.)
// {
+
// var genericType = type.GetGenericTypeDefinition();
// if (genericType == typeof(DistributedPropertyContext<>))
// {
@@ -2259,12 +2048,16 @@ var Codec = /*#__PURE__*/function () {
// }
// }
// }
+
// if (valueOrSource is IUserType)
// valueOrSource = (valueOrSource as IUserType).Get();
+
//if (valueOrSource is Func)
// valueOrSource = (valueOrSource as Func)(connection);
+
// if (valueOrSource == null)
// return TransmissionType.Compose(TransmissionTypeIdentifier.Null, null);
+
// type = valueOrSource.GetType();
if (this.composers[type] != undefined) {
@@ -2273,67 +2066,58 @@ var Codec = /*#__PURE__*/function () {
} else {
if (valueOrSource instanceof _TypedList["default"]) {
var genericType = this.getListType(valueOrSource);
-
var _results = _DataSerializer["default"].typedListComposer(valueOrSource, genericType, connection);
-
return _TransmissionType.TransmissionType.compose(_results.identifier, _results.data);
} else if (valueOrSource instanceof _TypedMap["default"]) {
var genericTypes = _TypedMap["default"].getTypes(valueOrSource);
-
var _results2 = _DataSerializer["default"].typedMapComposer(valueOrSource, genericTypes[0], genericTypes[1], connection);
-
return _TransmissionType.TransmissionType.compose(_results2.identifier, _results2.data);
} else if (valueOrSource instanceof _IResource["default"]) {
var _results3 = _DataSerializer["default"].resourceComposer(valueOrSource, connection);
-
return _TransmissionType.TransmissionType.compose(_results3.identifier, _results3.data);
} else if (valueOrSource instanceof _IRecord["default"]) {
var _results4 = _DataSerializer["default"].recordComposer(valueOrSource, connection);
-
return _TransmissionType.TransmissionType.compose(_results4.identifier, _results4.data);
} else if (valueOrSource instanceof _IEnum["default"]) {
var _results5 = _DataSerializer["default"].enumComposer(valueOrSource, connection);
-
return _TransmissionType.TransmissionType.compose(_results5.identifier, _results5.data);
} else if (valueOrSource instanceof _Tuple["default"]) {
var _results6 = _DataSerializer["default"].tupleComposer(valueOrSource, connection);
-
return _TransmissionType.TransmissionType.compose(_results6.identifier, _results6.data);
}
}
-
return _TransmissionType.TransmissionType.compose(_TransmissionType.TransmissionTypeIdentifier.Null, new _DC.DC(0));
- } ///
+ }
+
+ ///
/// Check if a resource is local to a given connection.
///
/// Resource to check.
/// DistributedConnection to check if the resource is local to it.
/// True, if the resource owner is the given connection, otherwise False.
-
}, {
key: "isLocalResource",
value: function isLocalResource(resource, connection) {
if (connection == null) return false;
-
if (resource instanceof _DistributedResource["default"]) {
if (resource._p.connection == connection) return true;
}
-
return false;
}
}]);
return Codec;
}();
-
-exports["default"] = Codec;
-(0, _defineProperty3["default"])(Codec, "fixedParsers", [[_DataDeserializer["default"].nullParser, _DataDeserializer["default"].booleanFalseParser, _DataDeserializer["default"].booleanTrueParser, _DataDeserializer["default"].notModifiedParser], [_DataDeserializer["default"].byteParser, _DataDeserializer["default"].sByteParser, _DataDeserializer["default"].char8Parser], [_DataDeserializer["default"].int16Parser, _DataDeserializer["default"].uInt16Parser, _DataDeserializer["default"].char16Parser], [_DataDeserializer["default"].int32Parser, _DataDeserializer["default"].uInt32Parser, _DataDeserializer["default"].float32Parser, _DataDeserializer["default"].resourceParser, _DataDeserializer["default"].localResourceParser], [_DataDeserializer["default"].int64Parser, _DataDeserializer["default"].uInt64Parser, _DataDeserializer["default"].float64Parser, _DataDeserializer["default"].dateTimeParser], [_DataDeserializer["default"].int128Parser, // int 128
-_DataDeserializer["default"].uInt128Parser, // uint 128
+//AsyncReply Parser(byte[] data, uint offset, uint length, DistributedConnection connection);
+(0, _defineProperty3["default"])(Codec, "fixedParsers", [[_DataDeserializer["default"].nullParser, _DataDeserializer["default"].booleanFalseParser, _DataDeserializer["default"].booleanTrueParser, _DataDeserializer["default"].notModifiedParser], [_DataDeserializer["default"].byteParser, _DataDeserializer["default"].sByteParser, _DataDeserializer["default"].char8Parser], [_DataDeserializer["default"].int16Parser, _DataDeserializer["default"].uInt16Parser, _DataDeserializer["default"].char16Parser], [_DataDeserializer["default"].int32Parser, _DataDeserializer["default"].uInt32Parser, _DataDeserializer["default"].float32Parser, _DataDeserializer["default"].resourceParser, _DataDeserializer["default"].localResourceParser], [_DataDeserializer["default"].int64Parser, _DataDeserializer["default"].uInt64Parser, _DataDeserializer["default"].float64Parser, _DataDeserializer["default"].dateTimeParser], [_DataDeserializer["default"].int128Parser,
+// int 128
+_DataDeserializer["default"].uInt128Parser,
+// uint 128
_DataDeserializer["default"].float128Parser]]);
(0, _defineProperty3["default"])(Codec, "dynamicParsers", [_DataDeserializer["default"].rawDataParser, _DataDeserializer["default"].stringParser, _DataDeserializer["default"].listParser, _DataDeserializer["default"].resourceListParser, _DataDeserializer["default"].recordListParser]);
(0, _defineProperty3["default"])(Codec, "typedParsers", [_DataDeserializer["default"].recordParser, _DataDeserializer["default"].typedListParser, _DataDeserializer["default"].typedMapParser, _DataDeserializer["default"].tupleParser, _DataDeserializer["default"].enumParser, _DataDeserializer["default"].constantParser]);
-(0, _defineProperty3["default"])(Codec, "composers", (_defineProperty2 = {}, (0, _defineProperty3["default"])(_defineProperty2, Boolean, _DataSerializer["default"].boolComposer), (0, _defineProperty3["default"])(_defineProperty2, _NotModified["default"], _DataSerializer["default"].notModifiedComposer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Char8, _DataSerializer["default"].char8Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Char16, _DataSerializer["default"].char16Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Int64, _DataSerializer["default"].int64Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.UInt64, _DataSerializer["default"].uInt64Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Int32, _DataSerializer["default"].int32Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.UInt32, _DataSerializer["default"].uInt32Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Int16, _DataSerializer["default"].int16Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.UInt16, _DataSerializer["default"].uInt16Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Int8, _DataSerializer["default"].int8Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.UInt8, _DataSerializer["default"].uInt8Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Float32, _DataSerializer["default"].float32Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Float64, _DataSerializer["default"].float64Composer), (0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Float128, _DataSerializer["default"].float128Composer), (0, _defineProperty3["default"])(_defineProperty2, Number, _DataSerializer["default"].numberComposer), (0, _defineProperty3["default"])(_defineProperty2, Date, _DataSerializer["default"].dateTimeComposer), (0, _defineProperty3["default"])(_defineProperty2, _DC.DC, _DataSerializer["default"].rawDataComposer), (0, _defineProperty3["default"])(_defineProperty2, Uint8Array, _DataSerializer["default"].rawDataComposer), (0, _defineProperty3["default"])(_defineProperty2, String, _DataSerializer["default"].stringComposer), (0, _defineProperty3["default"])(_defineProperty2, Array, _DataSerializer["default"].listComposer), (0, _defineProperty3["default"])(_defineProperty2, _ResourceArray["default"], _DataSerializer["default"].resourceListComposer), (0, _defineProperty3["default"])(_defineProperty2, _RecordArray["default"], _DataSerializer["default"].recordListComposer), (0, _defineProperty3["default"])(_defineProperty2, Map, _DataSerializer["default"].mapComposer), (0, _defineProperty3["default"])(_defineProperty2, _PropertyValueArray["default"], _DataSerializer["default"].propertyValueArrayComposer), _defineProperty2));
+(0, _defineProperty3["default"])(Codec, "composers", (_defineProperty2 = {}, (0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])(_defineProperty2, Boolean, _DataSerializer["default"].boolComposer), _NotModified["default"], _DataSerializer["default"].notModifiedComposer), _ExtendedTypes.Char8, _DataSerializer["default"].char8Composer), _ExtendedTypes.Char16, _DataSerializer["default"].char16Composer), _ExtendedTypes.Int64, _DataSerializer["default"].int64Composer), _ExtendedTypes.UInt64, _DataSerializer["default"].uInt64Composer), _ExtendedTypes.Int32, _DataSerializer["default"].int32Composer), _ExtendedTypes.UInt32, _DataSerializer["default"].uInt32Composer), _ExtendedTypes.Int16, _DataSerializer["default"].int16Composer), _ExtendedTypes.UInt16, _DataSerializer["default"].uInt16Composer), (0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])(_defineProperty2, _ExtendedTypes.Int8, _DataSerializer["default"].int8Composer), _ExtendedTypes.UInt8, _DataSerializer["default"].uInt8Composer), _ExtendedTypes.Float32, _DataSerializer["default"].float32Composer), _ExtendedTypes.Float64, _DataSerializer["default"].float64Composer), _ExtendedTypes.Float128, _DataSerializer["default"].float128Composer), Number, _DataSerializer["default"].numberComposer), Date, _DataSerializer["default"].dateTimeComposer), _DC.DC, _DataSerializer["default"].rawDataComposer), Uint8Array, _DataSerializer["default"].rawDataComposer), String, _DataSerializer["default"].stringComposer), (0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])((0, _defineProperty3["default"])(_defineProperty2, Array, _DataSerializer["default"].listComposer), _ResourceArray["default"], _DataSerializer["default"].resourceListComposer), _RecordArray["default"], _DataSerializer["default"].recordListComposer), Map, _DataSerializer["default"].mapComposer), _PropertyValueArray["default"], _DataSerializer["default"].propertyValueArrayComposer)));
-},{"../Core/AsyncBag.js":37,"../Core/AsyncReply.js":40,"../Net/IIP/DistributedPropertyContext.js":75,"../Net/IIP/DistributedResource.js":76,"../Resource/IResource.js":102,"../Resource/Template/TemplateType.js":114,"../Resource/Warehouse.js":116,"./BinaryList.js":48,"./DC.js":50,"./DataDeserializer.js":51,"./DataSerializer.js":52,"./ExtendedTypes.js":53,"./IEnum.js":55,"./IRecord.js":56,"./KeyList.js":57,"./NotModified.js":58,"./PropertyValue.js":61,"./PropertyValueArray.js":62,"./Record.js":63,"./RecordArray.js":64,"./ResourceArray.js":66,"./ResourceArrayType.js":67,"./TransmissionType.js":68,"./Tuple.js":69,"./TypedList.js":70,"./TypedMap.js":71,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/defineProperty":12,"@babel/runtime/helpers/interopRequireDefault":16}],50:[function(require,module,exports){
+},{"../Core/AsyncBag.js":39,"../Core/AsyncReply.js":42,"../Net/IIP/DistributedPropertyContext.js":78,"../Net/IIP/DistributedResource.js":79,"../Resource/IResource.js":114,"../Resource/Template/TemplateType.js":126,"../Resource/Warehouse.js":128,"./BinaryList.js":50,"./DC.js":52,"./DataDeserializer.js":53,"./DataSerializer.js":54,"./ExtendedTypes.js":55,"./IEnum.js":57,"./IRecord.js":58,"./KeyList.js":59,"./NotModified.js":60,"./PropertyValue.js":63,"./PropertyValueArray.js":64,"./Record.js":65,"./RecordArray.js":66,"./ResourceArray.js":68,"./ResourceArrayType.js":69,"./TransmissionType.js":70,"./Tuple.js":71,"./TypedList.js":72,"./TypedMap.js":73,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/defineProperty":14,"@babel/runtime/helpers/interopRequireDefault":18}],52:[function(require,module,exports){
/*
* Copyright (c) 2017 Ahmed Kh. Zamil
*
@@ -2359,56 +2143,39 @@ _DataDeserializer["default"].float128Parser]]);
/**
* Created by Ahmed Zamil on 25/07/2017.
*/
+
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports.BL = BL;
-exports.DC = exports["default"] = exports.Endian = exports.TWO_PWR_32 = exports.UNIX_EPOCH = void 0;
-
+exports["default"] = exports.UNIX_EPOCH = exports.TWO_PWR_32 = exports.Endian = exports.DC = void 0;
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
-var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
-
var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime/helpers/possibleConstructorReturn"));
-
var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime/helpers/getPrototypeOf"));
-
+var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
var _wrapNativeSuper2 = _interopRequireDefault(require("@babel/runtime/helpers/wrapNativeSuper"));
-
var _BinaryList = _interopRequireDefault(require("./BinaryList.js"));
-
var _Guid = _interopRequireDefault(require("./Guid.js"));
-
-function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = (0, _getPrototypeOf2["default"])(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2["default"])(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2["default"])(this, result); }; }
-
-function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } }
-
-var UNIX_EPOCH = 621355968000000000;
-exports.UNIX_EPOCH = UNIX_EPOCH;
-var TWO_PWR_32 = (1 << 16) * (1 << 16);
-exports.TWO_PWR_32 = TWO_PWR_32;
-var Endian = {
+function _callSuper(t, o, e) { return o = (0, _getPrototypeOf2["default"])(o), (0, _possibleConstructorReturn2["default"])(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], (0, _getPrototypeOf2["default"])(t).constructor) : o.apply(t, e)); }
+function _isNativeReflectConstruct() { try { var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); } catch (t) {} return (_isNativeReflectConstruct = function _isNativeReflectConstruct() { return !!t; })(); }
+var UNIX_EPOCH = exports.UNIX_EPOCH = 621355968000000000;
+var TWO_PWR_32 = exports.TWO_PWR_32 = (1 << 16) * (1 << 16);
+var Endian = exports.Endian = {
Big: 0,
Little: 1
};
-exports.Endian = Endian;
-
-var DC = /*#__PURE__*/function (_Uint8Array) {
+var DC = exports.DC = exports["default"] = /*#__PURE__*/function (_Uint8Array) {
(0, _inherits2["default"])(DC, _Uint8Array);
-
- var _super = _createSuper(DC);
-
function DC(bufferOrSize) {
var _this;
-
(0, _classCallCheck2["default"])(this, DC);
- _this = _super.call(this, bufferOrSize); //if (bufferOrSize instanceof ArrayBuffer) {
+ _this = _callSuper(this, DC, [bufferOrSize]);
+
+ //if (bufferOrSize instanceof ArrayBuffer) {
// this.buffer = bufferOrSize;
//}
//else
@@ -2419,7 +2186,6 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
_this.dv = new DataView(_this.buffer);
return _this;
}
-
(0, _createClass2["default"])(DC, [{
key: "append",
value: function append(src, offset, length) {
@@ -2530,12 +2296,8 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
value: function copy(offset, length, elementSize, func, dstType, endian) {
var rt = new dstType(length / elementSize);
var d = 0,
- end = offset + length;
-
- for (var i = offset; i < end; i += elementSize) {
- rt[d++] = func.call(this, i, endian);
- }
-
+ end = offset + length;
+ for (var i = offset; i < end; i += elementSize) rt[d++] = func.call(this, i, endian);
return rt;
}
}, {
@@ -2543,18 +2305,15 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
value: function paste(offset, length, elementSize, func) {
var rt = new dstType(length / elementSize);
var d = 0,
- end = offset + length;
-
- for (var i = offset; i < end; i += elementSize) {
- rt[d++] = func.call(this, i);
- }
-
+ end = offset + length;
+ for (var i = offset; i < end; i += elementSize) rt[d++] = func.call(this, i);
return rt;
}
}, {
key: "getInt16Array",
value: function getInt16Array(offset, length, endian) {
- return this.copy(offset, length, 2, this.getInt16, Int16Array, endian); //return new Int16Array(this.clip(offset, length).buffer);
+ return this.copy(offset, length, 2, this.getInt16, Int16Array, endian);
+ //return new Int16Array(this.clip(offset, length).buffer);
}
}, {
key: "getUint16Array",
@@ -2605,11 +2364,7 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
key: "getBooleanArray",
value: function getBooleanArray(offset, length) {
var rt = [];
-
- for (var i = 0; i < length; i++) {
- rt.push(this.getBoolean(offset + i));
- }
-
+ for (var i = 0; i < length; i++) rt.push(this.getBoolean(offset + i));
return rt;
}
}, {
@@ -2626,11 +2381,7 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
key: "getCharArray",
value: function getCharArray(offset, length, endian) {
var rt = [];
-
- for (var i = 0; i < length; i += 2) {
- rt.push(this.getChar(offset + i, endian));
- }
-
+ for (var i = 0; i < length; i += 2) rt.push(this.getChar(offset + i, endian));
return rt;
}
}, {
@@ -2639,12 +2390,10 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
var rt = "";
if (length == null) length = this.byteLength;
if (offset == null) offset = 0;
-
for (var i = offset; i < offset + length; i++) {
var h = this[i].toString(16);
rt += h.length == 1 ? "0" + h : h;
}
-
return rt;
}
}, {
@@ -2653,7 +2402,7 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
if (typeof StringView != "undefined") return new StringView(this.buffer, "UTF-8", offset, length);else {
var bytes = this.getUint8Array(offset, length);
var encodedString = String.fromCharCode.apply(null, bytes),
- decodedString = decodeURIComponent(escape(encodedString));
+ decodedString = decodeURIComponent(escape(encodedString));
return decodedString;
}
}
@@ -2662,17 +2411,16 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
value: function getStringArray(offset, length, endian) {
var rt = [];
var i = 0;
-
while (i < length) {
var cl = this.getUint32(offset + i, endian);
i += 4;
rt.push(this.getString(offset + i, cl));
i += cl;
}
-
return rt;
- } // @TODO: Test numbers with bit 7 of h = 1
+ }
+ // @TODO: Test numbers with bit 7 of h = 1
}, {
key: "getInt64",
value: function getInt64(offset, endian) {
@@ -2689,7 +2437,6 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
return parseInt(bi);
} else {
var _bi = BigInt(0);
-
_bi |= BigInt(this[offset++]);
_bi |= BigInt(this[offset++]) << 8n;
_bi |= BigInt(this[offset++]) << 16n;
@@ -2699,10 +2446,12 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
_bi |= BigInt(this[offset++]) << 48n;
_bi |= BigInt(this[offset++]) << 56n;
return parseInt(_bi);
- } // var h = this.getInt32(offset);
- // var l = this.getInt32(offset + 4);
- // return h * TWO_PWR_32 + ((l >= 0) ? l : TWO_PWR_32 + l);
+ }
+ // var h = this.getInt32(offset);
+ // var l = this.getInt32(offset + 4);
+
+ // return h * TWO_PWR_32 + ((l >= 0) ? l : TWO_PWR_32 + l);
}
}, {
key: "getUint64",
@@ -2720,7 +2469,6 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
return parseInt(bi);
} else {
var _bi2 = BigInt(0);
-
_bi2 |= BigInt(this[offset++]);
_bi2 |= BigInt(this[offset++]) << 8n;
_bi2 |= BigInt(this[offset++]) << 16n;
@@ -2730,18 +2478,17 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
_bi2 |= BigInt(this[offset++]) << 48n;
_bi2 |= BigInt(this[offset++]) << 56n;
return parseInt(_bi2);
- } //var h = this.getUint32(offset);
+ }
+
+ //var h = this.getUint32(offset);
//var l = this.getUint32(offset + 4);
//return h * TWO_PWR_32 + ((l >= 0) ? l : TWO_PWR_32 + l);
-
}
}, {
key: "setInt64",
value: function setInt64(offset, value, endian) {
var bi = BigInt(value);
-
var _byte = BigInt(0xFF);
-
if (endian == Endian.Big) {
this[offset++] = parseInt(bi >> 56n & _byte);
this[offset++] = parseInt(bi >> 48n & _byte);
@@ -2760,19 +2507,18 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
this[offset++] = parseInt(bi >> 40n & _byte);
this[offset++] = parseInt(bi >> 48n & _byte);
this[offset++] = parseInt(bi >> 56n & _byte);
- } //var l = (value % TWO_PWR_32) | 0;
+ }
+
+ //var l = (value % TWO_PWR_32) | 0;
//var h = (value / TWO_PWR_32) | 0;
//this.setInt32(offset, h);
//this.setInt32(offset + 4, l);
-
}
}, {
key: "setUint64",
value: function setUint64(offset, value, endian) {
var bi = BigInt(value);
-
var _byte2 = BigInt(0xFF);
-
if (endian == Endian.Big) {
this[offset++] = parseInt(bi >> 56n & _byte2);
this[offset++] = parseInt(bi >> 48n & _byte2);
@@ -2791,11 +2537,12 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
this[offset++] = parseInt(bi >> 40n & _byte2);
this[offset++] = parseInt(bi >> 48n & _byte2);
this[offset++] = parseInt(bi >> 56n & _byte2);
- } // var l = (value % TWO_PWR_32) | 0;
+ }
+
+ // var l = (value % TWO_PWR_32) | 0;
// var h = (value / TWO_PWR_32) | 0;
// this.setInt32(offset, h);
// this.setInt32(offset + 4, l);
-
}
}, {
key: "setDateTime",
@@ -2818,17 +2565,14 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
key: "getDateTimeArray",
value: function getDateTimeArray(offset, endian) {
var rt = [];
-
- for (var i = 0; i < length; i += 8) {
- rt.push(this.getDateTime(offset + i, endian));
- }
-
+ for (var i = 0; i < length; i += 8) rt.push(this.getDateTime(offset + i, endian));
return rt;
}
}, {
key: "getGuid",
value: function getGuid(offset) {
return new _Guid["default"](this.clip(offset, 16));
+
/*
var d = this.getUint8Array(offset, 16);
var rt = "";
@@ -2842,20 +2586,14 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
key: "getGuidArray",
value: function getGuidArray(offset, length) {
var rt = [];
-
- for (var i = 0; i < length; i += 16) {
- rt.push(this.getGuid(offset + i));
- }
-
+ for (var i = 0; i < length; i += 16) rt.push(this.getGuid(offset + i));
return rt;
}
}, {
key: "sequenceEqual",
value: function sequenceEqual(ar) {
if (ar.length != this.length) return false;else {
- for (var i = 0; i < this.length; i++) {
- if (ar[i] != this[i]) return false;
- }
+ for (var i = 0; i < this.length; i++) if (ar[i] != this[i]) return false;
}
return true;
}
@@ -2888,11 +2626,7 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
value: function fromHex(value) {
// convert hex to Uint8Array
var rt = new DC(value.length / 2);
-
- for (var i = 0; i < rt.length; i++) {
- rt[i] = parseInt(value.substr(i * 2, 2), 16);
- }
-
+ for (var i = 0; i < rt.length; i++) rt[i] = parseInt(value.substr(i * 2, 2), 16);
return rt;
}
}, {
@@ -2977,111 +2711,73 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
value: function stringToBytes(value) {
var utf8 = unescape(encodeURIComponent(value));
var rt = [];
-
- for (var i = 0; i < utf8.length; i++) {
- rt.push(utf8.charCodeAt(i));
- }
-
+ for (var i = 0; i < utf8.length; i++) rt.push(utf8.charCodeAt(i));
return new DC(rt);
}
}, {
key: "stringArrayToBytes",
value: function stringArrayToBytes(values) {
var list = new _BinaryList["default"]();
-
for (var i = 0; i < values.length; i++) {
var s = DC.stringToBytes(values[i]);
list.addUint32(s.length).addUint8Array(s);
}
-
return list.toArray();
}
}, {
key: "uint16ArrayToBytes",
value: function uint16ArrayToBytes(values, endian) {
var rt = new DC(values.length * 2);
-
- for (var i = 0; i < values.length; i++) {
- rt.setUint16(i * 2, values[i], endian);
- }
-
+ for (var i = 0; i < values.length; i++) rt.setUint16(i * 2, values[i], endian);
return rt;
}
}, {
key: "int16ArrayToBytes",
value: function int16ArrayToBytes(values, endian) {
var rt = new DC(values.length * 2);
-
- for (var i = 0; i < values.length; i++) {
- rt.setInt16(i * 2, values[i], endian);
- }
-
+ for (var i = 0; i < values.length; i++) rt.setInt16(i * 2, values[i], endian);
return rt;
}
}, {
key: "uint32ArrayToBytes",
value: function uint32ArrayToBytes(values, endian) {
var rt = new DC(values.length * 4);
-
- for (var i = 0; i < values.length; i++) {
- rt.setUint32(i * 4, values[i], endian);
- }
-
+ for (var i = 0; i < values.length; i++) rt.setUint32(i * 4, values[i], endian);
return rt;
}
}, {
key: "int32ArrayToBytes",
value: function int32ArrayToBytes(values, endian) {
var rt = new DC(values.length * 4);
-
- for (var i = 0; i < values.length; i++) {
- rt.setInt32(i * 4, values[i], endian);
- }
-
+ for (var i = 0; i < values.length; i++) rt.setInt32(i * 4, values[i], endian);
return rt;
}
}, {
key: "int64ArrayToBytes",
value: function int64ArrayToBytes(values, endian) {
var rt = new DC(values.length * 8);
-
- for (var i = 0; i < values.length; i++) {
- rt.setInt64(i * 8, values[i], endian);
- }
-
+ for (var i = 0; i < values.length; i++) rt.setInt64(i * 8, values[i], endian);
return rt;
}
}, {
key: "uint64ArrayToBytes",
value: function uint64ArrayToBytes(values, endian) {
var rt = new DC(values.length * 8);
-
- for (var i = 0; i < values.length; i++) {
- rt.setUint64(i * 8, values[i], endian);
- }
-
+ for (var i = 0; i < values.length; i++) rt.setUint64(i * 8, values[i], endian);
return rt;
}
}, {
key: "float32ArrayToBytes",
value: function float32ArrayToBytes(values, endian) {
var rt = new DC(values.length * 4);
-
- for (var i = 0; i < values.length; i++) {
- rt.setFloat32(i * 4, values[i], endian);
- }
-
+ for (var i = 0; i < values.length; i++) rt.setFloat32(i * 4, values[i], endian);
return rt;
}
}, {
key: "float64ArrayToBytes",
value: function float64ArrayToBytes(values, endian) {
var rt = new DC(values.length * 8);
-
- for (var i = 0; i < values.length; i++) {
- rt.setFloat64(i * 8, values[i], endian);
- }
-
+ for (var i = 0; i < values.length; i++) rt.setFloat64(i * 8, values[i], endian);
return rt;
}
}, {
@@ -3099,86 +2795,55 @@ var DC = /*#__PURE__*/function (_Uint8Array) {
}]);
return DC;
}( /*#__PURE__*/(0, _wrapNativeSuper2["default"])(Uint8Array));
-
-exports.DC = exports["default"] = DC;
-
function BL() {
return new _BinaryList["default"]();
}
-
;
-},{"./BinaryList.js":48,"./Guid.js":54,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/getPrototypeOf":14,"@babel/runtime/helpers/inherits":15,"@babel/runtime/helpers/interopRequireDefault":16,"@babel/runtime/helpers/possibleConstructorReturn":23,"@babel/runtime/helpers/wrapNativeSuper":33}],51:[function(require,module,exports){
+},{"./BinaryList.js":50,"./Guid.js":56,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/getPrototypeOf":16,"@babel/runtime/helpers/inherits":17,"@babel/runtime/helpers/interopRequireDefault":18,"@babel/runtime/helpers/possibleConstructorReturn":25,"@babel/runtime/helpers/wrapNativeSuper":35}],53:[function(require,module,exports){
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = exports.PropertyValueParserResults = void 0;
-
var _construct2 = _interopRequireDefault(require("@babel/runtime/helpers/construct"));
-
var _toConsumableArray2 = _interopRequireDefault(require("@babel/runtime/helpers/toConsumableArray"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _IEnum = _interopRequireDefault(require("./IEnum.js"));
-
var _Tuple = _interopRequireDefault(require("./Tuple.js"));
-
var _TemplateType = _interopRequireDefault(require("../Resource/Template/TemplateType.js"));
-
var _Warehouse = _interopRequireDefault(require("../Resource/Warehouse.js"));
-
var _AsyncBag = _interopRequireDefault(require("../Core/AsyncBag.js"));
-
var _AsyncReply = _interopRequireDefault(require("../Core/AsyncReply.js"));
-
var _DC = _interopRequireDefault(require("./DC.js"));
-
var _DistributedConnection = _interopRequireDefault(require("../Net/IIP/DistributedConnection.js"));
-
var _NotModified = _interopRequireDefault(require("./NotModified.js"));
-
var _RepresentationType = _interopRequireDefault(require("./RepresentationType.js"));
-
var _Codec = _interopRequireDefault(require("./Codec.js"));
-
var _TypedMap = _interopRequireDefault(require("./TypedMap.js"));
-
var _PropertyValueArray = _interopRequireDefault(require("./PropertyValueArray.js"));
-
var _PropertyValue = _interopRequireDefault(require("./PropertyValue.js"));
-
var _Record = _interopRequireDefault(require("./Record.js"));
-
-var _ExtendedTypes = require("../Data/ExtendedTypes.js");
-
var _AsyncException = _interopRequireDefault(require("../Core/AsyncException.js"));
-
var _ExceptionCode = _interopRequireDefault(require("../Core/ExceptionCode.js"));
-
var _ErrorType = _interopRequireDefault(require("../Core/ErrorType.js"));
-
-var PropertyValueParserResults = //final int size;
+var _ExtendedTypes = require("./ExtendedTypes.js");
+var PropertyValueParserResults = exports.PropertyValueParserResults = /*#__PURE__*/(0, _createClass2["default"])(
+//final int size;
///final AsyncReply reply;
+
function PropertyValueParserResults(size, reply) {
(0, _classCallCheck2["default"])(this, PropertyValueParserResults);
this.size = size;
this.reply = reply;
-};
-
-exports.PropertyValueParserResults = PropertyValueParserResults;
-
-var DataDeserializer = /*#__PURE__*/function () {
+});
+var DataDeserializer = exports["default"] = /*#__PURE__*/function () {
function DataDeserializer() {
(0, _classCallCheck2["default"])(this, DataDeserializer);
}
-
(0, _createClass2["default"])(DataDeserializer, null, [{
key: "nullParser",
value: function nullParser(data, offset, length, connection, requestSequence) {
@@ -3202,12 +2867,12 @@ var DataDeserializer = /*#__PURE__*/function () {
}, {
key: "byteParser",
value: function byteParser(data, offset, length, connection, requestSequence) {
- return new _AsyncReply["default"](data[offset]);
+ return new _AsyncReply["default"](new _ExtendedTypes.UInt8(data[offset]));
}
}, {
key: "sByteParser",
value: function sByteParser(data, offset, length, connection, requestSequence) {
- return new _AsyncReply["default"](data[offset] > 127 ? data[offset] - 256 : data[offset]);
+ return new _AsyncReply["default"](new _ExtendedTypes.Int8(data[offset] > 127 ? data[offset] - 256 : data[offset]));
}
}, {
key: "char16Parser",
@@ -3222,27 +2887,27 @@ var DataDeserializer = /*#__PURE__*/function () {
}, {
key: "int16Parser",
value: function int16Parser(data, offset, length, connection, requestSequence) {
- return new _AsyncReply["default"](data.getInt16(offset));
+ return new _AsyncReply["default"](new _ExtendedTypes.Int16(data.getInt16(offset)));
}
}, {
key: "uInt16Parser",
value: function uInt16Parser(data, offset, length, connection, requestSequence) {
- return new _AsyncReply["default"](data.getUint16(offset));
+ return new _AsyncReply["default"](new _ExtendedTypes.UInt16(data.getUint16(offset)));
}
}, {
key: "int32Parser",
value: function int32Parser(data, offset, length, connection, requestSequence) {
- return new _AsyncReply["default"](data.getInt32(offset));
+ return new _AsyncReply["default"](new _ExtendedTypes.Int32(data.getInt32(offset)));
}
}, {
key: "uInt32Parser",
value: function uInt32Parser(data, offset, length, connection, requestSequence) {
- return new _AsyncReply["default"](data.getUint32(offset));
+ return new _AsyncReply["default"](new _ExtendedTypes.UInt32(data.getUint32(offset)));
}
}, {
key: "float32Parser",
value: function float32Parser(data, offset, length, connection, requestSequence) {
- return new _AsyncReply["default"](data.getFloat32(offset));
+ return new _AsyncReply["default"](new _ExtendedTypes.Float32(data.getFloat32(offset)));
}
}, {
key: "float64Parser",
@@ -3288,7 +2953,6 @@ var DataDeserializer = /*#__PURE__*/function () {
var id = data.getUint32(offset, requestSequence);
return connection.fetch(id, requestSequence);
}
-
throw Error("Can't parse resource with no connection");
}
}, {
@@ -3314,27 +2978,19 @@ var DataDeserializer = /*#__PURE__*/function () {
var classId = data.getGuid(offset);
offset += 16;
length -= 16;
-
var template = _Warehouse["default"].getTemplateByClassId(classId, _TemplateType["default"].Record);
-
var initRecord = function initRecord(template) {
DataDeserializer.listParser(data, offset, length, connection, requestSequence).then(function (ar) {
var record;
-
if (template.definedType != null) {
record = new template.definedType();
} else {
record = new _Record["default"]();
}
-
- for (var i = 0; i < template.properties.length; i++) {
- record[template.properties[i].name] = ar[i];
- }
-
+ for (var i = 0; i < template.properties.length; i++) record[template.properties[i].name] = ar[i];
reply.trigger(record);
});
};
-
if (template != null) {
initRecord(template);
} else {
@@ -3349,7 +3005,6 @@ var DataDeserializer = /*#__PURE__*/function () {
return reply.triggerError(x);
});
}
-
return reply;
}
}, {
@@ -3363,9 +3018,7 @@ var DataDeserializer = /*#__PURE__*/function () {
var classId = data.getGuid(offset);
offset += 16;
var index = data[offset++];
-
var template = _Warehouse["default"].getTemplateByClassId(classId, _TemplateType["default"].Enum);
-
if (template != null) {
if (template.definedType != null) {
var enumVal = new template.definedType();
@@ -3401,18 +3054,14 @@ var DataDeserializer = /*#__PURE__*/function () {
key: "recordListParser",
value: function recordListParser(data, offset, length, connection, requestSequence) {
var rt = new _AsyncBag["default"]();
-
while (length > 0) {
var parsed = _Codec["default"].parse(data, offset, connection, requestSequence);
-
rt.add(parsed.reply);
-
if (parsed.size > 0) {
offset += parsed.size;
length -= parsed.size;
} else throw new Error("Error while parsing structured data");
}
-
rt.seal();
return rt;
}
@@ -3420,18 +3069,14 @@ var DataDeserializer = /*#__PURE__*/function () {
key: "resourceListParser",
value: function resourceListParser(data, offset, length, connection, requestSequence) {
var rt = new _AsyncBag["default"]();
-
while (length > 0) {
var parsed = _Codec["default"].parse(data, offset, connection, requestSequence);
-
rt.add(parsed.reply);
-
if (parsed.size > 0) {
offset += parsed.size;
length -= parsed.size;
} else throw new Error("Error while parsing structured data");
}
-
rt.seal();
return rt;
}
@@ -3439,55 +3084,42 @@ var DataDeserializer = /*#__PURE__*/function () {
key: "listParser",
value: function listParser(data, offset, length, connection, requestSequence) {
var rt = new _AsyncBag["default"]();
-
while (length > 0) {
var parsed = _Codec["default"].parse(data, offset, connection, requestSequence);
-
rt.add(parsed.reply);
-
if (parsed.size > 0) {
offset += parsed.size;
length -= parsed.size;
} else throw new Error("Error while parsing structured data");
}
-
rt.seal();
return rt;
}
}, {
key: "typedMapParser",
value: function typedMapParser(data, offset, length, connection, requestSequence) {
+ var _keyRep$type$getRunti, _valueRep$type$getRun;
// get key type
var keyRep = _RepresentationType["default"].parse(data, offset);
-
offset += keyRep.size;
length -= keyRep.size;
-
var valueRep = _RepresentationType["default"].parse(data, offset);
-
offset += valueRep.size;
length -= valueRep.size;
- var map = new _TypedMap["default"]();
+ var map = new (_TypedMap["default"].of((_keyRep$type$getRunti = keyRep.type.getRuntimeType()) !== null && _keyRep$type$getRunti !== void 0 ? _keyRep$type$getRunti : Object, (_valueRep$type$getRun = valueRep.type.getRuntimeType()) !== null && _valueRep$type$getRun !== void 0 ? _valueRep$type$getRun : Object))();
var rt = new _AsyncReply["default"]();
var results = new _AsyncBag["default"]();
-
while (length > 0) {
var parsed = _Codec["default"].parse(data, offset, connection, requestSequence);
-
results.add(parsed.reply);
-
if (parsed.size > 0) {
offset += parsed.size;
length -= parsed.size;
} else throw new Error("Error while parsing structured data");
}
-
results.seal();
results.then(function (ar) {
- for (var i = 0; i < ar.length; i += 2) {
- map.set(ar[i], ar[i + 1]);
- }
-
+ for (var i = 0; i < ar.length; i += 2) map.set(ar[i], ar[i + 1]);
rt.trigger(map);
});
return rt;
@@ -3500,28 +3132,21 @@ var DataDeserializer = /*#__PURE__*/function () {
var tupleSize = data[offset++];
length--;
var types = [];
-
for (var i = 0; i < tupleSize; i++) {
var _rep$type$getRuntimeT;
-
var rep = _RepresentationType["default"].parse(data, offset, requestSequence);
-
if (rep.type != null) types.push((_rep$type$getRuntimeT = rep.type.getRuntimeType()) !== null && _rep$type$getRuntimeT !== void 0 ? _rep$type$getRuntimeT : Object);
offset += rep.size;
length -= rep.size;
}
-
while (length > 0) {
var parsed = _Codec["default"].parse(data, offset, connection, requestSequence);
-
results.add(parsed.reply);
-
if (parsed.size > 0) {
offset += parsed.size;
length -= parsed.size;
} else throw new Error("Error while parsing structured data");
}
-
results.seal();
results.then(function (ar) {
rt.trigger((0, _construct2["default"])(_Tuple["default"].of.apply(_Tuple["default"], types), (0, _toConsumableArray2["default"])(ar)));
@@ -3531,57 +3156,49 @@ var DataDeserializer = /*#__PURE__*/function () {
}, {
key: "typedListParser",
value: function typedListParser(data, offset, length, connection, requestSequence) {
- var rt = new _AsyncBag["default"](); // get the type
+ var rt = new _AsyncBag["default"]();
+ // get the type
var rep = _RepresentationType["default"].parse(data, offset);
-
offset += rep.size;
length -= rep.size;
var runtimeType = rep.type.getRuntimeType();
rt.arrayType = runtimeType;
-
while (length > 0) {
var parsed = _Codec["default"].parse(data, offset, connection, requestSequence);
-
rt.add(parsed.reply);
-
if (parsed.size > 0) {
offset += parsed.size;
length -= parsed.size;
} else throw new Error("Error while parsing structured data");
}
-
rt.seal();
return rt;
}
}, {
key: "PropertyValueArrayParser",
- value: function PropertyValueArrayParser(data, offset, length, connection, requestSequence) //, bool ageIncluded = true)
+ value: function PropertyValueArrayParser(data, offset, length, connection, requestSequence)
+ //, bool ageIncluded = true)
{
var rt = new _AsyncBag["default"]();
DataDeserializer.listParser(data, offset, length, connection, requestSequence).then(function (x) {
var pvs = new _PropertyValueArray["default"]();
-
- for (var i = 0; i < x.length; i += 3) {
- pvs.push(new _PropertyValue["default"](x[2], x[0], x[1]));
- }
-
+ for (var i = 0; i < x.length; i += 3) pvs.push(new _PropertyValue["default"](x[2], x[0], x[1]));
rt.trigger(pvs);
});
return rt;
}
}, {
key: "propertyValueParser",
- value: function propertyValueParser(data, offset, connection, requestSequence) //, bool ageIncluded = true)
+ value: function propertyValueParser(data, offset, connection, requestSequence)
+ //, bool ageIncluded = true)
{
var reply = new _AsyncReply["default"]();
var age = data.getUint64(offset);
offset += 8;
var date = data.getDateTime(offset);
offset += 8;
-
var parsed = _Codec["default"].parse(data, offset, connection, requestSequence);
-
parsed.reply.then(function (value) {
reply.trigger(new _PropertyValue["default"](value, age, date));
});
@@ -3590,10 +3207,14 @@ var DataDeserializer = /*#__PURE__*/function () {
}, {
key: "historyParser",
value: function historyParser(data, offset, length, resource, connection, requestSequence) {
- throw new Error("Not implemented"); // @TODO
+ throw new Error("Not implemented");
+ // @TODO
// var list = new KeyList>();
+
// var reply = new AsyncReply>>();
+
// var bagOfBags = new AsyncBag();
+
// var ends = offset + length;
// while (offset < ends)
// {
@@ -3602,85 +3223,76 @@ var DataDeserializer = /*#__PURE__*/function () {
// list.Add(pt, null);
// var cs = data.GetUInt32(offset);
// offset += 4;
+
// var (len, pv) = PropertyValueParser(data, offset, connection);
+
// bagOfBags.Add(pv);// ParsePropertyValueArray(data, offset, cs, connection));
// offset += len;
// }
+
// bagOfBags.Seal();
+
// bagOfBags.Then(x =>
// {
// for (var i = 0; i < list.Count; i++)
// list[list.Keys.ElementAt(i)] = x[i];
+
// reply.Trigger(list);
// });
+
// return reply;
}
}]);
return DataDeserializer;
}();
-exports["default"] = DataDeserializer;
-
-},{"../Core/AsyncBag.js":37,"../Core/AsyncException.js":38,"../Core/AsyncReply.js":40,"../Core/ErrorType.js":41,"../Core/ExceptionCode.js":42,"../Data/ExtendedTypes.js":53,"../Net/IIP/DistributedConnection.js":74,"../Resource/Template/TemplateType.js":114,"../Resource/Warehouse.js":116,"./Codec.js":49,"./DC.js":50,"./IEnum.js":55,"./NotModified.js":58,"./PropertyValue.js":61,"./PropertyValueArray.js":62,"./Record.js":63,"./RepresentationType.js":65,"./Tuple.js":69,"./TypedMap.js":71,"@babel/runtime/helpers/classCallCheck":7,"@babel/runtime/helpers/construct":10,"@babel/runtime/helpers/createClass":11,"@babel/runtime/helpers/interopRequireDefault":16,"@babel/runtime/helpers/toConsumableArray":28}],52:[function(require,module,exports){
+},{"../Core/AsyncBag.js":39,"../Core/AsyncException.js":40,"../Core/AsyncReply.js":42,"../Core/ErrorType.js":43,"../Core/ExceptionCode.js":44,"../Net/IIP/DistributedConnection.js":77,"../Resource/Template/TemplateType.js":126,"../Resource/Warehouse.js":128,"./Codec.js":51,"./DC.js":52,"./ExtendedTypes.js":55,"./IEnum.js":57,"./NotModified.js":60,"./PropertyValue.js":63,"./PropertyValueArray.js":64,"./Record.js":65,"./RepresentationType.js":67,"./Tuple.js":71,"./TypedMap.js":73,"@babel/runtime/helpers/classCallCheck":8,"@babel/runtime/helpers/construct":12,"@babel/runtime/helpers/createClass":13,"@babel/runtime/helpers/interopRequireDefault":18,"@babel/runtime/helpers/toConsumableArray":30}],54:[function(require,module,exports){
"use strict";
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-
var _typeof = require("@babel/runtime/helpers/typeof");
-
Object.defineProperty(exports, "__esModule", {
value: true
});
exports["default"] = exports.DataSerializerComposeResults = void 0;
-
var _slicedToArray2 = _interopRequireDefault(require("@babel/runtime/helpers/slicedToArray"));
-
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
-
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
-
var _BinaryList = _interopRequireDefault(require("./BinaryList.js"));
-
var _Codec = _interopRequireDefault(require("./Codec.js"));
-
var _Warehouse = _interopRequireDefault(require("../Resource/Warehouse.js"));
-
var _TransmissionType = require("./TransmissionType.js");
-
var _DC = _interopRequireWildcard(require("./DC.js"));
-
var _RepresentationType = _interopRequireDefault(require("./RepresentationType.js"));
-
var _Tuple = _interopRequireDefault(require("./Tuple.js"));
-
-function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function _getRequireWildcardCache(nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); }
-
-function _interopRequireWildcard(obj, nodeInterop) { if (!nodeInterop && obj && obj.__esModule) { return obj; } if (obj === null || _typeof(obj) !== "object" && typeof obj !== "function") { return { "default": obj }; } var cache = _getRequireWildcardCache(nodeInterop); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj["default"] = obj; if (cache) { cache.set(obj, newObj); } return newObj; }
-
+function _getRequireWildcardCache(e) { if ("function" != typeof WeakMap) return null; var r = new WeakMap(), t = new WeakMap(); return (_getRequireWildcardCache = function _getRequireWildcardCache(e) { return e ? t : r; })(e); }
+function _interopRequireWildcard(e, r) { if (!r && e && e.__esModule) return e; if (null === e || "object" != _typeof(e) && "function" != typeof e) return { "default": e }; var t = _getRequireWildcardCache(r); if (t && t.has(e)) return t.get(e); var n = { __proto__: null }, a = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var u in e) if ("default" !== u && Object.prototype.hasOwnProperty.call(e, u)) { var i = a ? Object.getOwnPropertyDescriptor(e, u) : null; i && (i.get || i.set) ? Object.defineProperty(n, u, i) : n[u] = e[u]; } return n["default"] = e, t && t.set(e, n), n; }
function _createForOfIteratorHelper(o, allowArrayLike) { var it = typeof Symbol !== "undefined" && o[Symbol.iterator] || o["@@iterator"]; if (!it) { if (Array.isArray(o) || (it = _unsupportedIterableToArray(o)) || allowArrayLike && o && typeof o.length === "number") { if (it) o = it; var i = 0; var F = function F() {}; return { s: F, n: function n() { if (i >= o.length) return { done: true }; return { done: false, value: o[i++] }; }, e: function e(_e) { throw _e; }, f: F }; } throw new TypeError("Invalid attempt to iterate non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method."); } var normalCompletion = true, didErr = false, err; return { s: function s() { it = it.call(o); }, n: function n() { var step = it.next(); normalCompletion = step.done; return step; }, e: function e(_e2) { didErr = true; err = _e2; }, f: function f() { try { if (!normalCompletion && it["return"] != null) it["return"](); } finally { if (didErr) throw err; } } }; }
-
function _unsupportedIterableToArray(o, minLen) { if (!o) return; if (typeof o === "string") return _arrayLikeToArray(o, minLen); var n = Object.prototype.toString.call(o).slice(8, -1); if (n === "Object" && o.constructor) n = o.constructor.name; if (n === "Map" || n === "Set") return Array.from(o); if (n === "Arguments" || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) return _arrayLikeToArray(o, minLen); }
-
-function _arrayLikeToArray(arr, len) { if (len == null || len > arr.length) len = arr.length; for (var i = 0, arr2 = new Array(len); i < len; i++) { arr2[i] = arr[i]; } return arr2; }
-
-var DataSerializerComposeResults = // int identifier;
+function _arrayLikeToArray(arr, len) { if (len == null || len > arr.length) len = arr.length; for (var i = 0, arr2 = new Array(len); i < len; i++) arr2[i] = arr[i]; return arr2; } //import IRecord from './IRecord.js';
+//import DistributedResource from '../Net/IIP/DistributedResource.js';
+//import IResource from '../Resource/IResource.js';
+//import PropertyTemplate from '../Resource/Template/PropertyTemplate.js';
+//import PropertyValue from './PropertyValue.js';
+//import DistributedConnection from '../Net/IIP/DistributedConnection.js';
+var DataSerializerComposeResults = exports.DataSerializerComposeResults = /*#__PURE__*/(0, _createClass2["default"])(
+// int identifier;
//DC data;
+
function DataSerializerComposeResults(identifier, data) {
(0, _classCallCheck2["default"])(this, DataSerializerComposeResults);
this.identifier = identifier;
this.data = data;
-};
-
-exports.DataSerializerComposeResults = DataSerializerComposeResults;
-
-var DataSerializer = /*#__PURE__*/function () {
+});
+var DataSerializer = exports["default"] = /*#__PURE__*/function () {
function DataSerializer() {
(0, _classCallCheck2["default"])(this, DataSerializer);
}
-
(0, _createClass2["default"])(DataSerializer, null, [{
key: "historyComposer",
- value: //public delegate byte[] Serializer(object value);
+ value:
+ //public delegate byte[] Serializer(object value);
+
function historyComposer(history, connection) {
var prependLength = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : false;
throw new Error("Not implemented");
@@ -3738,7 +3350,6 @@ var DataSerializer = /*#__PURE__*/function () {
key: "numberComposer",
value: function numberComposer(value, connection) {
var rt = new _DC["default"](8);
-
if (Number.isInteger(value)) {
rt.setInt64(0, value);
return new DataSerializerComposeResults(_TransmissionType.TransmissionTypeIdentifier.Int64, rt);
@@ -3778,9 +3389,7 @@ var DataSerializer = /*#__PURE__*/function () {
key: "enumComposer",
value: function enumComposer(value, connection) {
if (value == null) return new DataSerializerComposeResults(_TransmissionType.TransmissionTypeIdentifier.Null, new _DC["default"](0));
-
var template = _Warehouse["default"].getTemplateByType(value.constructor);
-
if (template == null) return new DataSerializerComposeResults(_TransmissionType.TransmissionTypeIdentifier.Null, new _DC["default"](0));
var cts = template.constants.filter(function (x) {
return x.value == value.value;
@@ -3837,17 +3446,20 @@ var DataSerializer = /*#__PURE__*/function () {
}, {
key: "listComposer",
value: function listComposer(value, connection) {
- if (value == null) return new DataSerializerComposeResults(_TransmissionType.TransmissionTypeIdentifier.Null, new _DC["default"](0));else return new DataSerializerComposeResults(_TransmissionType.TransmissionTypeIdentifier.List, DataSerializer.arrayComposer(value, connection)); //var rt = new List();
+ if (value == null) return new DataSerializerComposeResults(_TransmissionType.TransmissionTypeIdentifier.Null, new _DC["default"](0));else return new DataSerializerComposeResults(_TransmissionType.TransmissionTypeIdentifier.List, DataSerializer.arrayComposer(value, connection));
+
+ //var rt = new List();
//var list = (IEnumerable)value;// ((List