Factors spawnMapWorker out to avoid creating functions.

Author: Sebmaster

lib/parallel.js

@@ -106,37 +106,38 @@
 		return this;
 	};
 
+	Parallel.prototype._spawnMapWorker = function (i, cb, done) {
+		var that = this;
+		var wrk = new Worker(that.options.path);
+		wrk.postMessage(Parallel.getWorkerSource(cb));
+		wrk.postMessage(that.data[i]);
+		wrk.onmessage = function (msg) {
+			wrk.terminate();
+			that.data[i] = msg.data;
+			done();
+		};
+	};
+
 	Parallel.prototype.map = function (cb) {
 		if (!this.data.length) {
 			return this.spawn(cb);
 		}
 
-		function spawnWorker(i) {
-			var wrk = new Worker(that.options.path);
-			wrk.postMessage(Parallel.getWorkerSource(cb));
-			wrk.postMessage(that.data[i]);
-			wrk.onmessage = function (msg) {
-				wrk.terminate();
-				that.data[i] = msg.data;
-				done();
-			};
-		}
-
 		var that = this;
 		var startedOps = 0;
 		var doneOps = 0;
 		function done() {
 			if (++doneOps === that.data.length) {
 				newOp.resolve(null, that.data);
 			} else if (startedOps < that.data.length) {
-				spawnWorker(++startedOps);
+				this._spawnMapWorker(++startedOps, cb, done);
 			}
 		}
 
 		var newOp = new Operation();
 		this.operation.then(function () {
 			for (; startedOps - doneOps < that.options.maxWorkers && startedOps < that.data.length; ++startedOps) {
-				spawnWorker(startedOps);
+				that._spawnMapWorker(startedOps, cb, done);
 			}
 		});
 		this.operation = newOp;