renowncoder
diff --git a/‎lib/Worker.js
Lines changed: 19 additions & 16 deletions b/‎lib/Worker.js
Lines changed: 19 additions & 16 deletions
diff --git a/‎lib/eval.js
Lines changed: 11 additions & 8 deletions b/‎lib/eval.js
Lines changed: 11 additions & 8 deletions
@@ -1,29 +1,32 @@
-var ps = require('child_process');
+/**
+ * @flow
+ */
+const ps = require('child_process');
 
 function Worker(url) {
-	var that = this;
-	this.process = ps.fork(url);
-	this.process.on('message', function (msg) {
-		if (that.onmessage) {
-			that.onmessage({ data: JSON.parse(msg) });
-		}
-	});
-	this.process.on('error', function (err) {
-		if (that.onerror) {
-			that.onerror(err);
-		}
-	});
+  const that = this;
+  this.process = ps.fork(url);
+  this.process.on('message', (msg) => {
+    if (that.onmessage) {
+      that.onmessage({ data: JSON.parse(msg) });
+    }
+  });
+  this.process.on('error', (err) => {
+    if (that.onerror) {
+      that.onerror(err);
+    }
+  });
 }
 
 Worker.prototype.onmessage = null;
 Worker.prototype.onerror = null;
 
 Worker.prototype.postMessage = function (obj) {
-	this.process.send(JSON.stringify({ data: obj }));
+  this.process.send(JSON.stringify({ data: obj }));
 };
 
 Worker.prototype.terminate = function () {
-	this.process.kill();
+  this.process.kill();
 };
 
-module.exports = Worker;
+module.exports = Worker;
@@ -1,11 +1,14 @@
-var isNode = typeof module !== 'undefined' && module.exports;
+/**
+ * @flow
+ */
+const isNode = typeof module !== 'undefined' && module.exports;
 
 if (isNode) {
-	process.once('message', function (code) {
-		eval(JSON.parse(code).data);
-	});
+  process.once('message', (code) => {
+    eval(JSON.parse(code).data);
+  });
 } else {
-	self.onmessage = function (code) {
-		eval(code.data);
-	};
-}
+  self.onmessage = function (code) {
+    eval(code.data);
+  };
+}