v0.5.1

* Fixed issue where line data was not being passed between transforms in the parser_stream
doug-martin · Aug 28, 2014 · 64b4fbe · 64b4fbe
1 parent 0957c0c
commit 64b4fbe
Show file tree

Hide file tree

Showing 4 changed files with 23 additions and 11 deletions.
diff --git a/History.md b/History.md
@@ -1,3 +1,7 @@
+# v0.5.1
+
+* Fixed issue where line data was not being passed between transforms in the parser_stream
+
 # v0.5.0
 
 * Added support for async transforms [#24](https://github.com/C2FO/fast-csv/issues/24)

diff --git a/docs/History.html b/docs/History.html
@@ -176,6 +176,10 @@
 
 
 
+<h1>v0.5.1</h1>
+<ul>
+<li>Fixed issue where line data was not being passed between transforms in the parser_stream</li>
+</ul>
 <h1>v0.5.0</h1>
 <ul>
 <li>Added support for async transforms <a href="https://github.com/C2FO/fast-csv/issues/24">#24</a></li>

diff --git a/lib/parser/parser_stream.js b/lib/parser/parser_stream.js
@@ -165,20 +165,24 @@ extended(ParserStream).extend({
     },
 
     _parse: function _parseLine(data, hasMoreData, cb) {
-        var row, count, ret, rows, self = this;
+        var rows, self = this;
         try {
             data = this.parser(data, hasMoreData);
             rows = data.rows;
-            if (!this._parsedHeaders) {
-                this.__processHeaders(rows, function (err) {
-                    if (err) {
-                        cb(err);
-                    } else {
-                        self.__processRows(rows, data, cb);
-                    }
-                });
+            if (rows.length) {
+                if (!this._parsedHeaders) {
+                    this.__processHeaders(rows, function (err) {
+                        if (err) {
+                            cb(err);
+                        } else {
+                            self.__processRows(rows, data, cb);
+                        }
+                    });
+                } else {
+                    this.__processRows(rows, data, cb);
+                }
             } else {
-                this.__processRows(rows, data, cb);
+                cb(null, data.line);
             }
         } catch (e) {
             this.emit("error", e);

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "fast-csv",
-    "version": "0.5.0",
+    "version": "0.5.1",
     "description": "CSV parser and writer",
     "main": "index.js",
     "scripts": {