Refactor spawning the worker.

Author: Sebmaster

lib/thread.js

@@ -89,12 +89,18 @@
 		}
 	};
 
+	Thread.prototype._spawnWorker = function (cb) {
+		var wrk = new Worker(this.options.path);
+		wrk.postMessage(Thread.getWorkerSource(cb));
+
+		return wrk;
+	};
+
 	Thread.prototype.spawn = function (cb) {
 		var that = this;
 		var newOp = new Operation();
 		this.operation.then(function () {
-			var wrk = new Worker(that.options.path);
-			wrk.postMessage(Thread.getWorkerSource(cb));
+			var wrk = that._spawnWorker(cb);
 			wrk.onmessage = function (msg) {
 				wrk.terminate();
 				that.data = msg.data;
@@ -108,8 +114,7 @@
 
 	Thread.prototype._spawnMapWorker = function (i, cb, done) {
 		var that = this;
-		var wrk = new Worker(that.options.path);
-		wrk.postMessage(Thread.getWorkerSource(cb));
+		var wrk = that._spawnWorker(cb);
 		wrk.onmessage = function (msg) {
 			wrk.terminate();
 			that.data[i] = msg.data;
@@ -146,8 +151,7 @@
 
 	Thread.prototype._spawnReduceWorker = function (data, cb, done) {
 		var that = this;
-		var wrk = new Worker(that.options.path);
-		wrk.postMessage(Thread.getWorkerSource(cb));
+		var wrk = that._spawnWorker(cb);
 		wrk.onmessage = function (msg) {
 			wrk.terminate();
 			that.data[that.data.length] = msg.data;