Skip to content
Snippets Groups Projects
Commit 14a9a911 authored by Jason Mulligan's avatar Jason Mulligan
Browse files

Updating syntax

parent c77e9d5a
No related branches found
No related tags found
No related merge requests found
...@@ -31,28 +31,22 @@ process.once("message", function (obj) { ...@@ -31,28 +31,22 @@ process.once("message", function (obj) {
postMessage: function postMessage(msg) { postMessage: function postMessage(msg) {
process.send(JSON.stringify({ data: msg })); process.send(JSON.stringify({ data: msg }));
}, },
onmessage: noop, onmessage: void 0,
onerror: noop, onerror: void 0,
addEventListener: function addEventListener(event, fn) { addEventListener: function addEventListener(event, fn) {
if (event === "message") { global["on" + event] = global.self["on" + event] = fn;
global.onmessage = global.self.onmessage = fn;
}
if (event === "error") {
global.onerror = global.self.onerror = fn;
}
} }
}; };
global.require = require; global.require = require;
global.importScripts = function () { global.importScripts = function () {
var scripts = undefined;
for (var _len = arguments.length, files = Array(_len), _key = 0; _key < _len; _key++) { for (var _len = arguments.length, files = Array(_len), _key = 0; _key < _len; _key++) {
files[_key] = arguments[_key]; files[_key] = arguments[_key];
} }
var scripts = undefined;
if (files.length > 0) { if (files.length > 0) {
scripts = files.map(function (file) { scripts = files.map(function (file) {
return fs.readFileSync(file, "utf8"); return fs.readFileSync(file, "utf8");
......
{ {
"name": "tiny-worker", "name": "tiny-worker",
"version": "1.1.2", "version": "1.1.3",
"description": "Tiny WebWorker for Server", "description": "Tiny WebWorker for Server",
"main": "lib/index.js", "main": "lib/index.js",
"scripts": { "scripts": {
......
...@@ -19,36 +19,30 @@ function toFunction (arg) { ...@@ -19,36 +19,30 @@ function toFunction (arg) {
} }
// Bootstraps the Worker // Bootstraps the Worker
process.once("message", function (obj) { process.once("message", obj => {
let exp = obj.isfn ? toFunction(obj.input) : fs.readFileSync(obj.input, "utf8"); let exp = obj.isfn ? toFunction(obj.input) : fs.readFileSync(obj.input, "utf8");
global.self = { global.self = {
close: function () { close: () => {
process.exit(0); process.exit(0);
}, },
postMessage: function (msg) { postMessage: msg => {
process.send(JSON.stringify({data: msg})); process.send(JSON.stringify({data: msg}));
}, },
onmessage: noop, onmessage: void 0,
onerror: noop, onerror: void 0,
addEventListener: function (event, fn) { addEventListener: (event, fn) => {
if (event === "message") { global["on" + event] = global.self["on" + event] = fn;
global.onmessage = global.self.onmessage = fn;
}
if (event === "error") {
global.onerror = global.self.onerror = fn;
}
} }
}; };
global.require = require; global.require = require;
global.importScripts = function (...files) { global.importScripts = (...files) => {
let scripts; let scripts;
if (files.length > 0) { if (files.length > 0) {
scripts = files.map(function (file) { scripts = files.map(file => {
return fs.readFileSync(file, "utf8"); return fs.readFileSync(file, "utf8");
}).join("\n"); }).join("\n");
...@@ -56,15 +50,15 @@ process.once("message", function (obj) { ...@@ -56,15 +50,15 @@ process.once("message", function (obj) {
} }
}; };
Object.keys(global.self).forEach(function (key) { Object.keys(global.self).forEach(key => {
global[key] = global.self[key]; global[key] = global.self[key];
}); });
process.on("message", function (msg) { process.on("message", msg => {
(global.onmessage || global.self.onmessage || noop)(JSON.parse(msg)); (global.onmessage || global.self.onmessage || noop)(JSON.parse(msg));
}); });
process.on("error", function (err) { process.on("error", err => {
(global.onerror || global.self.onerror || noop)(err); (global.onerror || global.self.onerror || noop)(err);
}); });
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment