Spaces:
Sleeping
Sleeping
| ; | |
| function asyncGeneratorStep(n, t, e, r, o, a, c) { try { var i = n[a](c), u = i.value; } catch (n) { return void e(n); } i.done ? t(u) : Promise.resolve(u).then(r, o); } | |
| function _asyncToGenerator(n) { return function () { var t = this, e = arguments; return new Promise(function (r, o) { var a = n.apply(t, e); function _next(n) { asyncGeneratorStep(a, r, o, _next, _throw, "next", n); } function _throw(n) { asyncGeneratorStep(a, r, o, _next, _throw, "throw", n); } _next(void 0); }); }; } | |
| const babel = require("./babel-core.cjs"); | |
| const handleMessage = require("./handle-message.cjs"); | |
| const worker_threads = require("worker_threads"); | |
| worker_threads.parentPort.addListener("message", _asyncToGenerator(function* ({ | |
| signal, | |
| port, | |
| action, | |
| payload | |
| }) { | |
| let response; | |
| try { | |
| if (babel.init) yield babel.init; | |
| response = { | |
| result: yield handleMessage(action, payload) | |
| }; | |
| } catch (error) { | |
| response = { | |
| error, | |
| errorData: Object.assign({}, error) | |
| }; | |
| } | |
| try { | |
| port.postMessage(response); | |
| } catch (_unused) { | |
| port.postMessage({ | |
| error: new Error("Cannot serialize worker response") | |
| }); | |
| } finally { | |
| port.close(); | |
| Atomics.store(signal, 0, 1); | |
| Atomics.notify(signal, 0); | |
| } | |
| })); | |
| //# sourceMappingURL=index.cjs.map | |