Merge pull request kubernetes-client#289 from brendandburns/stream

Switch from json-stream to byline.

Author: k8s-ci-robot

package-lock.json

@@ -52,10 +52,10 @@
     "@types/request": "^2.47.1",
     "@types/underscore": "^1.8.9",
     "@types/ws": "^6.0.1",
+    "byline": "^5.0.0",
     "execa": "1.0.0",
     "isomorphic-ws": "^4.0.1",
     "js-yaml": "^3.13.1",
-    "json-stream": "^1.0.0",
     "jsonpath-plus": "^0.19.0",
     "request": "^2.88.0",
     "shelljs": "^0.8.2",
@@ -64,6 +64,7 @@
     "ws": "^6.1.0"
   },
   "devDependencies": {
+    "@types/byline": "^4.2.31",
     "@types/chai": "^4.1.6",
     "@types/chai-as-promised": "^7.1.0",
     "@types/mocha": "^5.2.7",

package.json

@@ -1,4 +1,4 @@
-import JSONStream = require('json-stream');
+import byline = require('byline');
 import request = require('request');
 import { KubeConfig } from './config';
 
@@ -55,8 +55,15 @@ export class Watch {
         };
         this.config.applyToRequest(requestOptions);
 
-        const stream = new JSONStream();
-        stream.on('data', (data) => callback(data.type, data.object));
+        const stream = byline.createStream();
+        stream.on('data', (line) => {
+            try {
+                const data = JSON.parse(line);
+                callback(data.type, data.object);
+            } catch (ignore) {
+                // ignore parse errors
+            }
+        });
         const req = this.requestImpl.webRequest(requestOptions, (error, response, body) => {
             if (error) {
                 done(error);