|
|
@ -147,15 +147,15 @@ function chunkFn(results, streamer, file) |
|
|
|
|
|
|
|
|
|
|
|
parser = streamer; |
|
|
|
parser = streamer; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (printStepChecked) |
|
|
|
|
|
|
|
console.log("Chunk data:", results.data.length, results); |
|
|
|
|
|
|
|
|
|
|
|
if (pauseChecked) |
|
|
|
if (pauseChecked) |
|
|
|
{ |
|
|
|
{ |
|
|
|
console.log("Pausing; " + results.data.length + " rows in chunk; file:", file); |
|
|
|
console.log("Pausing; " + results.data.length + " rows in chunk; file:", file); |
|
|
|
streamer.pause(); |
|
|
|
streamer.pause(); |
|
|
|
return; |
|
|
|
return; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if (printStepChecked) |
|
|
|
|
|
|
|
console.log("Chunk data:", results.data.length, results); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
function errorFn(error, file) |
|
|
|
function errorFn(error, file) |
|
|
|