|
|
|
@ -898,14 +898,12 @@ if (!Array.isArray)
@@ -898,14 +898,12 @@ if (!Array.isArray)
|
|
|
|
|
this._onCsvData = function(results) |
|
|
|
|
{ |
|
|
|
|
var data = results.data; |
|
|
|
|
for (var i = 0; i < data.length; i++) { |
|
|
|
|
if (!stream.push(data[i]) && !this._handle.paused()) { |
|
|
|
|
if (!stream.push(data) && !this._handle.paused()) { |
|
|
|
|
// the writeable consumer buffer has filled up
|
|
|
|
|
// so we need to pause until more items
|
|
|
|
|
// can be processed
|
|
|
|
|
this._handle.pause(); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
this._onCsvComplete = function() |
|
|
|
|