v5.4.4

package.json

@@ -3,7 +3,7 @@
   "author": "Austin K Smith",
   "description": "100% Vanilla Javascript Multithreading & Parallel Execution Library",
   "homepage": "http://www.hamsters.io/",
-  "version": "5.4.3",
+  "version": "5.4.4",
   "main": "build/hamsters.node.min.js",
   "scripts": {
     "build": "rm -rf ./build && webpack --config ./hamsters.webpack.config.js && npm run copy-common",

src/core/data.js

@@ -83,7 +83,7 @@ class data {
     let i = 0;
     let outputLength = output.length;
     for (i; i < outputLength; i++) {
-      task.input.array[(index.start + i)] = output[i];
+      task.output[(index.start + i)] = output[i];
     }
   }
 

src/core/pool.js

@@ -37,7 +37,6 @@ class pool {
   * @param {function} reject - onError method
   */
   addWorkToPending(index, task, resolve, reject) {
-    debugger;
     if(hamstersHabitat.debug) {
       task.scheduler.metrics.threads[task.scheduler.count].enqueued_at = Date.now();
     }
@@ -174,15 +173,15 @@ class pool {
   * @param {function} resolve - onSuccess method
   */
   returnOutputAndRemoveTask(task, resolve) {
-    if (task.sort) {
-      resolve(hamstersData.sortOutput(task.input.array, task.sort));
-    } else {
-      resolve(task.input.array);
-    }
     if(hamstersHabitat.debug) {
       task.scheduler.metrics.completed_at = Date.now();
       console.info("Hamsters.js Task Completed: ", task);
     }
+    if (task.sort) {
+      resolve(hamstersData.sortOutput(task.output, task.sort));
+    } else {
+      resolve(task.output);
+    }
   }
 
   removeFromRunning(task, threadId) {
@@ -200,7 +199,7 @@ class pool {
     if(task.scheduler.threads !== 1) {
       hamstersData.addThreadOutputWithIndex(task, index, output);
     } else {
-      task.input.array = output;
+      task.output = output;
     }
   }
 

src/hamsters.js

@@ -22,7 +22,7 @@ class hamstersjs {
   constructor() {
     'use strict';
 
-    this.version = '5.4.3';
+    this.version = '5.4.4';
     this.habitat = hamstersHabitat;
     this.data = hamstersData;
     this.pool = hamstersPool;
@@ -78,6 +78,7 @@ class hamstersjs {
   hamstersTask(params, functionToRun) {
     let task = {
       input: params,
+      output: [],
       scheduler: {
         count: 0,
         threads: (params.threads ? params.threads : 1),
@@ -91,7 +92,6 @@ class hamstersjs {
       }
     } else {
       params.hamstersJob = this.data.prepareFunction(functionToRun);
-      debugger;
       task.scheduler.indexes = params.indexes ? params.indexes : this.data.getSubArrayIndexes(params.array, task.scheduler.threads);
     }
     if(this.habitat.debug) {

tests/hamsters.js

@@ -40,8 +40,7 @@ describe("Hamsters.js", () => {
         }
       }, function (results) {
         expect(typeof results).toBe('object');
-        debugger;
-        expect(results[i]).toEqual(params.array[i]);
+        expect(results[i]).toEqual(params.array[i] * 2);
         done();
       }, function (error) {
         console.error(error);
@@ -57,11 +56,11 @@ describe("Hamsters.js", () => {
 
       hamsters.promise(params, function () {
         for (let j = 0; j < params.array.length; j++) {
-          rtn.data.push(params.array[j] * 2);
+          rtn.data.push(params.array[j] * 4);
         }
       }).then(function (results) {
         expect(typeof results).toBe('object');
-        expect(results[i]).toEqual(params.array[i]);
+        expect(results[i]).toEqual(params.array[i] * 4);
         done();
       }).catch(function (error) {
         console.error(error);