Merge pull request #9 from pipelinedb/add-try-catch-for-large-data

Add try catch for large data

Author: arwong09

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipelinedb/stride",
-  "version": "1.2.0",
+  "version": "1.2.1",
   "description": "Stride.io JavaScript API client",
   "main": "index.js",
   "scripts": {

src/stride.js

@@ -115,7 +115,11 @@ function SubscribeObjectTransform() {
     let objects = chunk.toString('utf8').trim().split('\r\n')
     for (let obj of objects) {
       if (obj = obj.trim()) {
-        obj = JSON.parse(obj)
+        try {
+          obj = JSON.parse(obj)
+        } catch(e) {
+          return console.error(e)
+        }
         if (obj && typeof obj === 'object') this.push(obj)
       }
     }