v5.3.6 - Working real threading using react native 0.62

build/common/reactNativeHamster.js

@@ -14,50 +14,16 @@ import { self } from 'react-native-hamsters';
 (function () {
     self.params = {};
     self.rtn = {};
-
-    self.onmessage = (message) => {
-      params = JSON.parse(incomingMessage.data);
+    self.onmessage = message => {
+      params = JSON.parse(message);
       rtn = {
         data: [],
-        dataType: (params.dataType ? params.dataType.toLowerCase() : null)
       };
-      eval("(" + params.hamstersJob + ")")();
+      eval(params.hamstersJob);
       return returnResponse(rtn);
     };
 
-    const returnResponse = (rtn) => {
+    const returnResponse = rtn => {
       return postMessage(JSON.stringify(rtn));
     }
-
-    const typedArrayFromBuffer = (dataType, buffer) => {
-      const types = {
-        'Uint32': Uint32Array,
-        'Uint16': Uint16Array,
-        'Uint8': Uint8Array,
-        'Uint8clamped': Uint8ClampedArray,
-        'Int32': Int32Array,
-        'Int16': Int16Array,
-        'Int8': Int8Array,
-        'Float32': Float32Array,
-        'Float64': Float64Array
-      };
-      if (!types[dataType]) {
-        return buffer;
-      }
-      return new types[dataType](buffer);
-    }
-
-    const prepareTransferBuffers = (rtn, buffers) => {
-      Object.keys(rtn).forEach(function(key) {
-        var item = rtn[key];
-        if(typeof item.buffer !== 'undefined') {
-          buffers.push(item.buffer);
-        } else {
-          if(Array.isArray(rtn[key]) && typeof ArrayBuffer !== 'undefined') {
-            buffers.push(new ArrayBuffer(rtn[key]));
-          }
-        }
-      });
-      return postMessage(rtn, buffers);
-    }
 }());

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.3.5",
+  "version": "5.3.6",
   "main": "build/hamsters.node.min.js",
   "scripts": {
     "build": "rm -rf ./build && webpack --config ./hamsters.webpack.config.js && npm run copy-common",

src/common/reactNativeHamster.js

@@ -14,50 +14,16 @@ import { self } from 'react-native-hamsters';
 (function () {
     self.params = {};
     self.rtn = {};
-
-    self.onmessage = (message) => {
-      params = JSON.parse(incomingMessage.data);
+    self.onmessage = message => {
+      params = JSON.parse(message);
       rtn = {
-        data: [],
-        dataType: (params.dataType ? params.dataType.toLowerCase() : null)
+        data: []
       };
-      eval("(" + params.hamstersJob + ")")();
+      eval(params.hamstersJob);
       return returnResponse(rtn);
     };
 
-    const returnResponse = (rtn) => {
-      return postMessage(JSON.stringify(rtn));
-    }
-
-    const typedArrayFromBuffer = (dataType, buffer) => {
-      const types = {
-        'Uint32': Uint32Array,
-        'Uint16': Uint16Array,
-        'Uint8': Uint8Array,
-        'Uint8clamped': Uint8ClampedArray,
-        'Int32': Int32Array,
-        'Int16': Int16Array,
-        'Int8': Int8Array,
-        'Float32': Float32Array,
-        'Float64': Float64Array
-      };
-      if (!types[dataType]) {
-        return buffer;
-      }
-      return new types[dataType](buffer);
-    }
-
-    const prepareTransferBuffers = (rtn, buffers) => {
-      Object.keys(rtn).forEach(function(key) {
-        var item = rtn[key];
-        if(typeof item.buffer !== 'undefined') {
-          buffers.push(item.buffer);
-        } else {
-          if(Array.isArray(rtn[key]) && typeof ArrayBuffer !== 'undefined') {
-            buffers.push(new ArrayBuffer(rtn[key]));
-          }
-        }
-      });
-      return postMessage(rtn, buffers);
+    const returnResponse = rtn => {
+      return self.postMessage(JSON.stringify(rtn));
     }
 }());

src/core/pool.js

@@ -195,10 +195,14 @@ class pool {
   trainHamster(pool, habitat, threadId, task, hamster, resolve, reject) {
     let onThreadResponse = function(message) {
       pool.removeFromRunning(task, threadId);
-      if(typeof message.data.data !== "undefined") {
-        task.output[threadId] = message.data.data;
+      if(habitat.reactNative) {
+        task.output[threadId] = JSON.parse(message);
       } else {
-        task.output[threadId] = (habitat.reactNative ? JSON.parse(message.data) : message.data);
+        if(typeof message.data.data !== "undefined") {
+          task.output[threadId] = message.data.data;
+        } else {
+          task.output[threadId] = message.data;
+        }
       }
       if (task.workers.length === 0 && task.count === task.threads) {
         pool.returnOutputAndRemoveTask(task, resolve);

src/core/version.js

@@ -13,7 +13,7 @@
 
 const majorVersion = 5;
 const minorVersion = 3;
-const patchVersion = 5;
+const patchVersion = 6;
 const hamstersVersion = `${majorVersion}.${minorVersion}.${patchVersion}`;
 
 if(typeof module !== 'undefined' && typeof module.exports !== 'undefined') {