Implemented reader framing

tj · tj · commit c9b1e669a9d3 · 2010-09-26T11:59:51.000-07:00
diff --git a/lib/log.js b/lib/log.js
@@ -104,10 +104,13 @@ Log.prototype = {
    */
   
   read: function(){
-    var self = this;
+    var buf = ''
+      , self = this;
     this.stream.setEncoding('ascii');
     this.stream.on('data', function(chunk){
-      chunk.split('\n').map(function(line){
+      buf += chunk;
+      if ('\n' != buf[buf.length - 1]) return;
+      buf.split('\n').map(function(line){
         if (!line.length) return;
         var captures = line.match(/^\[([^\]]+)\] (\w+) (.*)/);
         var obj = {
@@ -118,6 +121,7 @@ Log.prototype = {
         };
         self.emit('line', obj);
       });
+      buf = '';
     });
   },
   
