stream: handle empty input streams

CHANGELOG.md

@@ -9,6 +9,7 @@ New features:
 
 Fix:
 
+* stream: handle empty input streams
 * cast: function may return non-string values
 * stream: pass stream options without modification
 

lib/es5/index.js

@@ -316,8 +316,13 @@ function (_Transform) {
           trimChars = _this$state.trimChars;
       var buf;
 
-      if (previousBuf === undefined && nextBuf !== undefined) {
-        buf = nextBuf;
+      if (previousBuf === undefined) {
+        if (nextBuf === undefined) {
+          this.push(null);
+          return;
+        } else {
+          buf = nextBuf;
+        }
       } else if (previousBuf !== undefined && nextBuf === undefined) {
         buf = previousBuf;
       } else {

lib/index.js

@@ -210,8 +210,13 @@ class Parser extends Transform {
     let {record_delimiter} = this.options
     const {previousBuf, rawBuffer, escapeIsQuote, trimChars} = this.state
     let buf
-    if(previousBuf === undefined && nextBuf !== undefined){
-      buf = nextBuf
+    if(previousBuf === undefined){
+      if(nextBuf === undefined){
+        this.push(null)
+        return
+      }else{
+        buf = nextBuf
+      }
     }else if(previousBuf !== undefined && nextBuf === undefined){
       buf = previousBuf
     }else{

test/api.pipe.coffee

@@ -1,5 +1,6 @@
 
 fs = require 'fs'
+{ Readable } = require 'stream'
 generate = require 'csv-generate'
 parse = require '../lib'
 
@@ -45,4 +46,14 @@ describe 'API pipe', ->
       next()
     rs.pipe(parser)
 
+  it 'handle empty string', (next) ->
+    s = new Readable()
+    s._read = ->
+      @push null
+    s.pipe parse
+      delimiter: ','
+    , (err, records) ->
+      records.should.eql [] unless err
+      next err
+