Merge pull request #1 from tmpvar/cleanup-write

reduction of JSONStream#write

lib/json-stream.js

@@ -17,29 +17,20 @@ var JSONStream = module.exports.JSONStream = function () {
 util.inherits(JSONStream, Stream);
 
 JSONStream.prototype.write = function (data) {
-  var start = 0, stop = 0, chunk, parsed;
 
-  data = data.toString('utf8');
+  data = this._buffer + data.toString('utf8');
 
-  if (this._buffer) {
-    data = this._buffer + data;
-  }
+  var lines = data.split('\n'),
+      that = this;
 
-  while ((stop = data.indexOf('\n', start + 1)) !== -1) {
-    chunk = data.substr(start, stop - start);
-    parsed = false;
+  this._buffer = lines.pop();
+
+  lines.forEach(function(line) {
     try {
-      chunk = JSON.parse(chunk);
-      parsed = true;
+      that.emit('data', JSON.parse(line));
     }
     catch (_) { }
-
-    if (parsed) {
-      this.emit('data', chunk);
-    }
-    start = stop + 1;
-  }
-  this._buffer = data.substr(start);
+  });
 
   return !this.paused;
 };