Merge pull request #44 from doug-martin/master

v0.4.1
C2FO · Jun 11, 2014 · 850fb75 · 850fb75
2 parents a78a590 + cc6aced
commit 850fb75
Show file tree

Hide file tree

Showing 4 changed files with 23 additions and 4 deletions.
diff --git a/History.md b/History.md
@@ -1,3 +1,7 @@
+# v0.4.1
+
+* Fixed race condition that occured if you called pause during a flush.
+
 # v0.4.0
 
 * Fixed misspelling of `delimiter` [#40](https://github.com/C2FO/fast-csv/issues/40)

diff --git a/docs/History.html b/docs/History.html
@@ -176,6 +176,10 @@
 
 
 
+<h1>v0.4.1</h1>
+<ul>
+<li>Fixed race condition that occured if you called pause during a flush.</li>
+</ul>
 <h1>v0.4.0</h1>
 <ul>
 <li>Fixed misspelling of <code>delimiter</code> <a href="https://github.com/C2FO/fast-csv/issues/40">#40</a></li>

diff --git a/lib/parser_stream.js b/lib/parser_stream.js
@@ -173,13 +173,24 @@ extended(ParserStream).extend({
         }
     },
 
+    __doFlush: function (callback) {
+        //increment row count so we aren't 0 based
+        this.emit("end");
+        callback();
+    },
+
     _flush: function (callback) {
         if (this.lines) {
             this._parse(this.lines, false);
         }
-        //increment row count so we aren't 0 based
-        this.emit("end");
-        callback();
+        if (!this.paused) {
+            this.__doFlush(callback);
+        } else {
+            var self = this;
+            this.__pausedDone = function () {
+                self.__doFlush(callback);
+            };
+        }
     },
 
     __validate: function (data, index) {

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