Skip to content

Commit 23532d5

Browse files
committed
emit end on error, because it seems like csv parser doesn't go further when an error occurs
1 parent 8b28eb5 commit 23532d5

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

lib/read.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ function processRead(msg, cfg) {
5050
parser.on('error', function emitError(error) {
5151
debug('Error reported by CSV read', error);
5252
that.emit('error', error);
53+
that.emit('end');
5354
});
5455

5556
debug('Sending GET request to url=%s', csvURL);

0 commit comments

Comments
 (0)