@remote-ui/rpc
Advanced tools
Comparing version
@@ -78,4 +78,2 @@ "use strict"; | ||
function _typeof(obj) { if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); } | ||
function _toConsumableArray(arr) { return _arrayWithoutHoles(arr) || _iterableToArray(arr) || _nonIterableSpread(); } | ||
@@ -89,2 +87,4 @@ | ||
function _typeof(obj) { "@babel/helpers - typeof"; if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); } | ||
function _slicedToArray(arr, i) { return _arrayWithHoles(arr) || _iterableToArrayLimit(arr, i) || _nonIterableRest(); } | ||
@@ -98,2 +98,6 @@ | ||
function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(_next, _throw); } } | ||
function _asyncToGenerator(fn) { return function () { var self = this, args = arguments; return new Promise(function (resolve, reject) { var gen = fn.apply(self, args); function _next(value) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err); } _next(undefined); }); }; } | ||
var APPLY = 0; | ||
@@ -144,81 +148,90 @@ var RESULT = 1; | ||
function listener(event) { | ||
var _i, _arr, _listener, data, stackFrame, _data, id, target, args, func, result, _toWire, _toWire2, serializedResult, transferables, name, message, stack; | ||
function listener(_x) { | ||
return _listener.apply(this, arguments); | ||
} | ||
return regeneratorRuntime.async(function listener$(_context) { | ||
while (1) { | ||
switch (_context.prev = _context.next) { | ||
case 0: | ||
for (_i = 0, _arr = _toConsumableArray(eventListeners); _i < _arr.length; _i++) { | ||
_listener = _arr[_i]; | ||
function _listener() { | ||
_listener = _asyncToGenerator( | ||
/*#__PURE__*/ | ||
regeneratorRuntime.mark(function _callee(event) { | ||
var _i3, _arr2, _listener2, data, stackFrame, _data2, id, target, args, func, result, _toWire7, _toWire8, serializedResult, transferables, name, message, stack; | ||
_listener(event); | ||
} | ||
return regeneratorRuntime.wrap(function _callee$(_context) { | ||
while (1) { | ||
switch (_context.prev = _context.next) { | ||
case 0: | ||
for (_i3 = 0, _arr2 = _toConsumableArray(eventListeners); _i3 < _arr2.length; _i3++) { | ||
_listener2 = _arr2[_i3]; | ||
data = event.data; | ||
_listener2(event); | ||
} | ||
if (!(data == null)) { | ||
_context.next = 4; | ||
break; | ||
} | ||
data = event.data; | ||
return _context.abrupt("return"); | ||
if (!(data == null)) { | ||
_context.next = 4; | ||
break; | ||
} | ||
case 4: | ||
_context.t0 = data[0]; | ||
_context.next = _context.t0 === TERMINATE ? 7 : _context.t0 === APPLY ? 9 : 30; | ||
break; | ||
return _context.abrupt("return"); | ||
case 7: | ||
terminate(); | ||
return _context.abrupt("break", 30); | ||
case 4: | ||
_context.t0 = data[0]; | ||
_context.next = _context.t0 === TERMINATE ? 7 : _context.t0 === APPLY ? 9 : 30; | ||
break; | ||
case 9: | ||
stackFrame = new _memory.StackFrame(); | ||
_data = _slicedToArray(data, 4), id = _data[1], target = _data[2], args = _data[3]; | ||
func = activeApi.get(target); | ||
_context.prev = 12; | ||
case 7: | ||
terminate(); | ||
return _context.abrupt("break", 30); | ||
if (!(func == null)) { | ||
_context.next = 15; | ||
break; | ||
} | ||
case 9: | ||
stackFrame = new _memory.StackFrame(); | ||
_data2 = _slicedToArray(data, 4), id = _data2[1], target = _data2[2], args = _data2[3]; | ||
func = activeApi.get(target); | ||
_context.prev = 12; | ||
throw new Error("No '".concat(target, "' method is exposed on this endpoint")); | ||
if (!(func == null)) { | ||
_context.next = 15; | ||
break; | ||
} | ||
case 15: | ||
_context.next = 17; | ||
return regeneratorRuntime.awrap(func.apply(void 0, _toConsumableArray(fromWire(args, [stackFrame])))); | ||
throw new Error("No '".concat(target, "' method is exposed on this endpoint")); | ||
case 17: | ||
result = _context.sent; | ||
_toWire = toWire(result), _toWire2 = _slicedToArray(_toWire, 2), serializedResult = _toWire2[0], transferables = _toWire2[1]; | ||
messenger.postMessage([RESULT, id, undefined, serializedResult], transferables); | ||
_context.next = 26; | ||
break; | ||
case 15: | ||
_context.next = 17; | ||
return func.apply(void 0, _toConsumableArray(fromWire(args, [stackFrame]))); | ||
case 22: | ||
_context.prev = 22; | ||
_context.t1 = _context["catch"](12); | ||
name = _context.t1.name, message = _context.t1.message, stack = _context.t1.stack; | ||
messenger.postMessage([RESULT, id, { | ||
name: name, | ||
message: message, | ||
stack: stack | ||
}]); | ||
case 17: | ||
result = _context.sent; | ||
_toWire7 = toWire(result), _toWire8 = _slicedToArray(_toWire7, 2), serializedResult = _toWire8[0], transferables = _toWire8[1]; | ||
messenger.postMessage([RESULT, id, undefined, serializedResult], transferables); | ||
_context.next = 26; | ||
break; | ||
case 26: | ||
_context.prev = 26; | ||
stackFrame.release(); | ||
return _context.finish(26); | ||
case 22: | ||
_context.prev = 22; | ||
_context.t1 = _context["catch"](12); | ||
name = _context.t1.name, message = _context.t1.message, stack = _context.t1.stack; | ||
messenger.postMessage([RESULT, id, { | ||
name: name, | ||
message: message, | ||
stack: stack | ||
}]); | ||
case 29: | ||
return _context.abrupt("break", 30); | ||
case 26: | ||
_context.prev = 26; | ||
stackFrame.release(); | ||
return _context.finish(26); | ||
case 30: | ||
case "end": | ||
return _context.stop(); | ||
case 29: | ||
return _context.abrupt("break", 30); | ||
case 30: | ||
case "end": | ||
return _context.stop(); | ||
} | ||
} | ||
} | ||
}, null, null, [[12, 22, 26, 29]]); | ||
}, _callee, null, [[12, 22, 26, 29]]); | ||
})); | ||
return _listener.apply(this, arguments); | ||
} | ||
@@ -246,5 +259,5 @@ | ||
var _data2 = _slicedToArray(data, 4), | ||
errorResult = _data2[2], | ||
value = _data2[3]; | ||
var _data = _slicedToArray(data, 4), | ||
errorResult = _data[2], | ||
value = _data[3]; | ||
@@ -265,6 +278,6 @@ if (errorResult == null) { | ||
var _toWire3 = toWire(args), | ||
_toWire4 = _slicedToArray(_toWire3, 2), | ||
serializedArgs = _toWire4[0], | ||
transferables = _toWire4[1]; | ||
var _toWire = toWire(args), | ||
_toWire2 = _slicedToArray(_toWire, 2), | ||
serializedArgs = _toWire2[0], | ||
transferables = _toWire2[1]; | ||
@@ -326,7 +339,7 @@ messenger.postMessage([APPLY, id, property, serializedArgs], transferables); | ||
var _result = value.map(function (item) { | ||
var _toWire5 = toWire(item), | ||
_toWire6 = _slicedToArray(_toWire5, 2), | ||
result = _toWire6[0], | ||
_toWire6$ = _toWire6[1], | ||
nestedTransferables = _toWire6$ === void 0 ? [] : _toWire6$; | ||
var _toWire3 = toWire(item), | ||
_toWire4 = _slicedToArray(_toWire3, 2), | ||
result = _toWire4[0], | ||
_toWire4$ = _toWire4[1], | ||
nestedTransferables = _toWire4$ === void 0 ? [] : _toWire4$; | ||
@@ -341,7 +354,7 @@ transferables.push.apply(transferables, _toConsumableArray(nestedTransferables)); | ||
var result = Object.keys(value).reduce(function (object, key) { | ||
var _toWire7 = toWire(value[key]), | ||
_toWire8 = _slicedToArray(_toWire7, 2), | ||
result = _toWire8[0], | ||
_toWire8$ = _toWire8[1], | ||
nestedTransferables = _toWire8$ === void 0 ? [] : _toWire8$; | ||
var _toWire5 = toWire(value[key]), | ||
_toWire6 = _slicedToArray(_toWire5, 2), | ||
result = _toWire6[0], | ||
_toWire6$ = _toWire6[1], | ||
nestedTransferables = _toWire6$ === void 0 ? [] : _toWire6$; | ||
@@ -348,0 +361,0 @@ transferables.push.apply(transferables, _toConsumableArray(nestedTransferables)); |
@@ -67,3 +67,3 @@ "use strict"; | ||
function _typeof(obj) { if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); } | ||
function _typeof(obj) { "@babel/helpers - typeof"; if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); } | ||
@@ -70,0 +70,0 @@ function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } } |
@@ -60,2 +60,6 @@ "use strict"; | ||
function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(_next, _throw); } } | ||
function _asyncToGenerator(fn) { return function () { var self = this, args = arguments; return new Promise(function (resolve, reject) { var gen = fn.apply(self, args); function _next(value) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err); } _next(undefined); }); }; } | ||
function _slicedToArray(arr, i) { return _arrayWithHoles(arr) || _iterableToArrayLimit(arr, i) || _nonIterableRest(); } | ||
@@ -99,70 +103,82 @@ | ||
portToFunction.set(port1, func); | ||
port1.addEventListener('message', function listener(_ref5) { | ||
var data, stackFrame, _data, _id2, args, _func, retainedBy, result, _toWire2, _toWire3, serializedResult, transferables, name, message, stack; | ||
port1.addEventListener('message', | ||
/*#__PURE__*/ | ||
function () { | ||
var _listener = _asyncToGenerator( | ||
/*#__PURE__*/ | ||
regeneratorRuntime.mark(function _callee(_ref5) { | ||
var data, stackFrame, _data, _id2, args, _func, retainedBy, result, _toWire2, _toWire3, serializedResult, transferables, name, message, stack; | ||
return regeneratorRuntime.async(function listener$(_context) { | ||
while (1) { | ||
switch (_context.prev = _context.next) { | ||
case 0: | ||
data = _ref5.data; | ||
return regeneratorRuntime.wrap(function _callee$(_context) { | ||
while (1) { | ||
switch (_context.prev = _context.next) { | ||
case 0: | ||
data = _ref5.data; | ||
if (!(data == null)) { | ||
_context.next = 3; | ||
if (!(data == null)) { | ||
_context.next = 3; | ||
break; | ||
} | ||
return _context.abrupt("return"); | ||
case 3: | ||
_context.t0 = data[0]; | ||
_context.next = _context.t0 === RELEASE ? 6 : _context.t0 === APPLY ? 10 : 30; | ||
break; | ||
} | ||
return _context.abrupt("return"); | ||
case 6: | ||
port1.removeEventListener('message', listener); | ||
port1.close(); | ||
functionStore["delete"](func); | ||
return _context.abrupt("break", 30); | ||
case 3: | ||
_context.t0 = data[0]; | ||
_context.next = _context.t0 === RELEASE ? 6 : _context.t0 === APPLY ? 10 : 30; | ||
break; | ||
case 10: | ||
stackFrame = new _memory.StackFrame(); | ||
_data = _slicedToArray(data, 3), _id2 = _data[1], args = _data[2]; | ||
_func = portToFunction.get(port1); | ||
_context.prev = 13; | ||
retainedBy = (0, _memory.isMemoryManageable)(_func) ? [stackFrame].concat(_toConsumableArray(_func[_types.RETAINED_BY])) : [stackFrame]; | ||
_context.next = 17; | ||
return _func.apply(void 0, _toConsumableArray(_fromWire(args, retainedBy))); | ||
case 6: | ||
port1.removeEventListener('message', listener); | ||
port1.close(); | ||
functionStore["delete"](func); | ||
return _context.abrupt("break", 30); | ||
case 17: | ||
result = _context.sent; | ||
_toWire2 = _toWire(result), _toWire3 = _slicedToArray(_toWire2, 2), serializedResult = _toWire3[0], transferables = _toWire3[1]; | ||
port1.postMessage([RESULT, _id2, undefined, serializedResult], transferables); | ||
_context.next = 26; | ||
break; | ||
case 10: | ||
stackFrame = new _memory.StackFrame(); | ||
_data = _slicedToArray(data, 3), _id2 = _data[1], args = _data[2]; | ||
_func = portToFunction.get(port1); | ||
_context.prev = 13; | ||
retainedBy = (0, _memory.isMemoryManageable)(_func) ? [stackFrame].concat(_toConsumableArray(_func[_types.RETAINED_BY])) : [stackFrame]; | ||
_context.next = 17; | ||
return regeneratorRuntime.awrap(_func.apply(void 0, _toConsumableArray(_fromWire(args, retainedBy)))); | ||
case 22: | ||
_context.prev = 22; | ||
_context.t1 = _context["catch"](13); | ||
name = _context.t1.name, message = _context.t1.message, stack = _context.t1.stack; | ||
port1.postMessage([RESULT, _id2, { | ||
name: name, | ||
message: message, | ||
stack: stack | ||
}]); | ||
case 17: | ||
result = _context.sent; | ||
_toWire2 = _toWire(result), _toWire3 = _slicedToArray(_toWire2, 2), serializedResult = _toWire3[0], transferables = _toWire3[1]; | ||
port1.postMessage([RESULT, _id2, undefined, serializedResult], transferables); | ||
_context.next = 26; | ||
break; | ||
case 26: | ||
_context.prev = 26; | ||
stackFrame.release(); | ||
return _context.finish(26); | ||
case 22: | ||
_context.prev = 22; | ||
_context.t1 = _context["catch"](13); | ||
name = _context.t1.name, message = _context.t1.message, stack = _context.t1.stack; | ||
port1.postMessage([RESULT, _id2, { | ||
name: name, | ||
message: message, | ||
stack: stack | ||
}]); | ||
case 29: | ||
return _context.abrupt("break", 30); | ||
case 26: | ||
_context.prev = 26; | ||
stackFrame.release(); | ||
return _context.finish(26); | ||
case 30: | ||
case "end": | ||
return _context.stop(); | ||
} | ||
} | ||
}, _callee, null, [[13, 22, 26, 29]]); | ||
})); | ||
case 29: | ||
return _context.abrupt("break", 30); | ||
function listener(_x) { | ||
return _listener.apply(this, arguments); | ||
} | ||
case 30: | ||
case "end": | ||
return _context.stop(); | ||
} | ||
} | ||
}, null, null, [[13, 22, 26, 29]]); | ||
}); | ||
return listener; | ||
}()); | ||
port1.start(); | ||
@@ -169,0 +185,0 @@ return [[id, port2], [port2]]; |
@@ -66,2 +66,6 @@ "use strict"; | ||
function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(_next, _throw); } } | ||
function _asyncToGenerator(fn) { return function () { var self = this, args = arguments; return new Promise(function (resolve, reject) { var gen = fn.apply(self, args); function _next(value) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err); } _next(undefined); }); }; } | ||
var APPLY = 11; | ||
@@ -82,100 +86,109 @@ var RESULT = 12; | ||
function listener(_ref2) { | ||
var data, _data, id, _data2, _id, func, _data3, callId, _error, _result, stackFrame, _data4, _callId, funcId, args, _func, _ref3, name, message, stack, retainedBy, _result2, _toWire, _toWire2, serializedResult, transferables, _name, _message, _stack; | ||
function listener(_x) { | ||
return _listener.apply(this, arguments); | ||
} | ||
return regeneratorRuntime.async(function listener$(_context) { | ||
while (1) { | ||
switch (_context.prev = _context.next) { | ||
case 0: | ||
data = _ref2.data; | ||
function _listener() { | ||
_listener = _asyncToGenerator( | ||
/*#__PURE__*/ | ||
regeneratorRuntime.mark(function _callee(_ref2) { | ||
var data, _data, id, _data2, _id2, func, _data3, callId, _error2, _result, stackFrame, _data4, _callId, funcId, args, _func, _ref3, name, message, stack, retainedBy, _result2, _toWire3, _toWire4, serializedResult, transferables, _name, _message, _stack; | ||
if (!(data == null)) { | ||
_context.next = 3; | ||
break; | ||
} | ||
return regeneratorRuntime.wrap(function _callee$(_context) { | ||
while (1) { | ||
switch (_context.prev = _context.next) { | ||
case 0: | ||
data = _ref2.data; | ||
return _context.abrupt("return"); | ||
if (!(data == null)) { | ||
_context.next = 3; | ||
break; | ||
} | ||
case 3: | ||
_context.t0 = data[0]; | ||
_context.next = _context.t0 === REVOKE ? 6 : _context.t0 === RELEASE ? 9 : _context.t0 === RESULT ? 13 : _context.t0 === APPLY ? 17 : 41; | ||
break; | ||
return _context.abrupt("return"); | ||
case 6: | ||
_data = _slicedToArray(data, 2), id = _data[1]; | ||
idsToProxy["delete"](id); | ||
return _context.abrupt("break", 41); | ||
case 3: | ||
_context.t0 = data[0]; | ||
_context.next = _context.t0 === REVOKE ? 6 : _context.t0 === RELEASE ? 9 : _context.t0 === RESULT ? 13 : _context.t0 === APPLY ? 17 : 41; | ||
break; | ||
case 9: | ||
_data2 = _slicedToArray(data, 2), _id = _data2[1]; | ||
func = idsToFunction.get(_id); | ||
case 6: | ||
_data = _slicedToArray(data, 2), id = _data[1]; | ||
idsToProxy["delete"](id); | ||
return _context.abrupt("break", 41); | ||
if (func) { | ||
idsToFunction["delete"](_id); | ||
functionsToId["delete"](func); | ||
} | ||
case 9: | ||
_data2 = _slicedToArray(data, 2), _id2 = _data2[1]; | ||
func = idsToFunction.get(_id2); | ||
return _context.abrupt("break", 41); | ||
if (func) { | ||
idsToFunction["delete"](_id2); | ||
functionsToId["delete"](func); | ||
} | ||
case 13: | ||
_data3 = _slicedToArray(data, 4), callId = _data3[1], _error = _data3[2], _result = _data3[3]; | ||
callIdsToResolver.get(callId)(_error, _result); | ||
callIdsToResolver["delete"](callId); | ||
return _context.abrupt("break", 41); | ||
return _context.abrupt("break", 41); | ||
case 17: | ||
stackFrame = new _memory.StackFrame(); | ||
_data4 = _slicedToArray(data, 4), _callId = _data4[1], funcId = _data4[2], args = _data4[3]; | ||
_func = idsToFunction.get(funcId); | ||
case 13: | ||
_data3 = _slicedToArray(data, 4), callId = _data3[1], _error2 = _data3[2], _result = _data3[3]; | ||
callIdsToResolver.get(callId)(_error2, _result); | ||
callIdsToResolver["delete"](callId); | ||
return _context.abrupt("break", 41); | ||
if (!(_func == null)) { | ||
_context.next = 24; | ||
break; | ||
} | ||
case 17: | ||
stackFrame = new _memory.StackFrame(); | ||
_data4 = _slicedToArray(data, 4), _callId = _data4[1], funcId = _data4[2], args = _data4[3]; | ||
_func = idsToFunction.get(funcId); | ||
_ref3 = new Error('You attempted to call a function that was already revoked.'), name = _ref3.name, message = _ref3.message, stack = _ref3.stack; | ||
messenger.postMessage([RESULT, _callId, { | ||
name: name, | ||
message: message, | ||
stack: stack | ||
}]); | ||
return _context.abrupt("return"); | ||
if (!(_func == null)) { | ||
_context.next = 24; | ||
break; | ||
} | ||
case 24: | ||
_context.prev = 24; | ||
retainedBy = (0, _memory.isMemoryManageable)(_func) ? [stackFrame].concat(_toConsumableArray(_func[_types.RETAINED_BY])) : [stackFrame]; | ||
_context.next = 28; | ||
return regeneratorRuntime.awrap(_func.apply(void 0, _toConsumableArray(_fromWire(args, retainedBy)))); | ||
_ref3 = new Error('You attempted to call a function that was already revoked.'), name = _ref3.name, message = _ref3.message, stack = _ref3.stack; | ||
messenger.postMessage([RESULT, _callId, { | ||
name: name, | ||
message: message, | ||
stack: stack | ||
}]); | ||
return _context.abrupt("return"); | ||
case 28: | ||
_result2 = _context.sent; | ||
_toWire = toWire(_result2), _toWire2 = _slicedToArray(_toWire, 2), serializedResult = _toWire2[0], transferables = _toWire2[1]; | ||
messenger.postMessage([RESULT, _callId, undefined, serializedResult], transferables); | ||
_context.next = 37; | ||
break; | ||
case 24: | ||
_context.prev = 24; | ||
retainedBy = (0, _memory.isMemoryManageable)(_func) ? [stackFrame].concat(_toConsumableArray(_func[_types.RETAINED_BY])) : [stackFrame]; | ||
_context.next = 28; | ||
return _func.apply(void 0, _toConsumableArray(_fromWire(args, retainedBy))); | ||
case 33: | ||
_context.prev = 33; | ||
_context.t1 = _context["catch"](24); | ||
_name = _context.t1.name, _message = _context.t1.message, _stack = _context.t1.stack; | ||
messenger.postMessage([RESULT, _callId, { | ||
name: _name, | ||
message: _message, | ||
stack: _stack | ||
}]); | ||
case 28: | ||
_result2 = _context.sent; | ||
_toWire3 = toWire(_result2), _toWire4 = _slicedToArray(_toWire3, 2), serializedResult = _toWire4[0], transferables = _toWire4[1]; | ||
messenger.postMessage([RESULT, _callId, undefined, serializedResult], transferables); | ||
_context.next = 37; | ||
break; | ||
case 37: | ||
_context.prev = 37; | ||
stackFrame.release(); | ||
return _context.finish(37); | ||
case 33: | ||
_context.prev = 33; | ||
_context.t1 = _context["catch"](24); | ||
_name = _context.t1.name, _message = _context.t1.message, _stack = _context.t1.stack; | ||
messenger.postMessage([RESULT, _callId, { | ||
name: _name, | ||
message: _message, | ||
stack: _stack | ||
}]); | ||
case 40: | ||
return _context.abrupt("break", 41); | ||
case 37: | ||
_context.prev = 37; | ||
stackFrame.release(); | ||
return _context.finish(37); | ||
case 41: | ||
case "end": | ||
return _context.stop(); | ||
case 40: | ||
return _context.abrupt("break", 41); | ||
case 41: | ||
case "end": | ||
return _context.stop(); | ||
} | ||
} | ||
} | ||
}, null, null, [[24, 33, 37, 40]]); | ||
}, _callee, null, [[24, 33, 37, 40]]); | ||
})); | ||
return _listener.apply(this, arguments); | ||
} | ||
@@ -187,5 +200,5 @@ | ||
if (functionsToId.has(func)) { | ||
var _id2 = functionsToId.get(func); | ||
var _id = functionsToId.get(func); | ||
return [_id2]; | ||
return [_id]; | ||
} | ||
@@ -256,5 +269,5 @@ | ||
} else { | ||
var _error2 = new Error(); | ||
var _error = new Error(); | ||
Object.assign(_error2, errorResult); | ||
Object.assign(_error, errorResult); | ||
reject(errorResult); | ||
@@ -265,6 +278,6 @@ } | ||
var _toWire3 = toWire(args), | ||
_toWire4 = _slicedToArray(_toWire3, 2), | ||
serializedArgs = _toWire4[0], | ||
transferables = _toWire4[1]; | ||
var _toWire = toWire(args), | ||
_toWire2 = _slicedToArray(_toWire, 2), | ||
serializedArgs = _toWire2[0], | ||
transferables = _toWire2[1]; | ||
@@ -271,0 +284,0 @@ messenger.postMessage([APPLY, callId, id, serializedArgs], transferables); |
{ | ||
"name": "@remote-ui/rpc", | ||
"version": "0.0.1", | ||
"version": "0.0.2", | ||
"publishConfig": { | ||
@@ -9,6 +9,6 @@ "access": "public" | ||
"devDependencies": { | ||
"@types/uuid": "^3.4.6", | ||
"uuid": "^3.3.3" | ||
"@types/uuid": "^3.4.7", | ||
"uuid": "^3.4.0" | ||
}, | ||
"gitHead": "c983682d8602256e4f8fef925d098785b300d0c8" | ||
"gitHead": "c40615dd893295f310c5b726f1463e70cc45be3c" | ||
} |
Sorry, the diff of this file is not supported yet
361114
8.79%4665
0.76%