From b5e8891391114fb67854a83fda4c7666ebea197c Mon Sep 17 00:00:00 2001
From: Tareq Hossain <tareq@trueskills.com>
Date: Thu, 15 Oct 2015 13:45:25 -0700
Subject: [PATCH] Added option "emit_type". So, that we emit all the data with
 one event "lines" or continue to emit "line" by line.

---
 index.js | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/index.js b/index.js
index 6b754fd..2dbf65a 100644
--- a/index.js
+++ b/index.js
@@ -60,7 +60,6 @@ Tail = (function(_super) {
 
         debug("reading:", block.fd, size, start);
         fs.read(block.fd, buffer, 0, size, start, function(err, bytesRead, buff) {
-          var chunk, parts, _i, _len, _results;
 
           if (err) { return self.emit('error', err); };
 
@@ -68,14 +67,13 @@ Tail = (function(_super) {
 
           self.bookmarks[block.fd] += bytesRead;
           buff = buff.toString("utf-8");
-          self.buffer += buff;
-          parts = self.buffer.split(self.separator);
-          self.buffer = parts.pop();
-
-          _results = [];
-          for (_i = 0, _len = parts.length; _i < _len; _i++) {
-            chunk = parts[_i];
-            _results.push(self.emit("line", chunk));
+          if (self.emit_type == 'lines') {
+              self.emit('lines', buff);
+          } else {
+            self.buffer += buff;
+            var parts = self.buffer.split(self.separator);
+            self.buffer = parts.pop();
+            parts.map(function(chunk) { self.emit('line', chunk); });
           }
           next();
         });
@@ -100,6 +98,7 @@ Tail = (function(_super) {
    * @param {Object} options options object
    * @param {Integer} options.start (optional) start offset to read data from file, default: 0
    * @param {Integer} options.interval (optional) interval to monitor for changes, default: 5000ms 
+   * @param {String} options.emit_type (optional) emit line by line or blocks of line, default: 'line'
    *
    */
   function Tail(filename, separator, options) {
@@ -119,6 +118,7 @@ Tail = (function(_super) {
     });
 
     this.interval = options.interval || 5000;
+    this.emit_type = options.emit_type || 'line';
     this.blockSize = options.blockSize || 1024 * 1024; // 1 MB by default
    
     this.fd = null;