Added tests to add coverage for #214

test/issues/issue214.test.ts

@@ -0,0 +1,44 @@
+import { EOL } from 'os';
+import * as assert from 'assert';
+import * as csv from '../../src';
+import { RowMap } from '../../build/src/parser';
+
+
+describe('Issue #214 - https://github.com/C2FO/fast-csv/issues/214', () => {
+    const CSV_CONTENT = [
+        'firstName,lastName,emailAddress',
+        'First1,Last1,[email protected]',
+        'First2,Last2,[email protected]',
+        'First3,Last3,[email protected]',
+        'First4,Last4,[email protected]',
+    ].join(EOL);
+
+    const expectedRows = [
+        { firstName: 'First1', lastName: 'Last1', emailAddress: '[email protected]' },
+        { firstName: 'First2', lastName: 'Last2', emailAddress: '[email protected]' },
+        { firstName: 'First3', lastName: 'Last3', emailAddress: '[email protected]' },
+        { firstName: 'First4', lastName: 'Last4', emailAddress: '[email protected]' },
+    ];
+
+    it('should emit data when using the on method', (next) => {
+        const rows: RowMap[] = [];
+        csv.parseString(CSV_CONTENT, { headers: true })
+            .on('data', (r: RowMap) => rows.push(r))
+            .on('error', next)
+            .on('end', (count: number) => {
+                assert.deepStrictEqual(rows, expectedRows);
+                next();
+            });
+    });
+
+    it('should emit data when using the addListener method', (next) => {
+        const rows: RowMap[] = [];
+        csv.parseString(CSV_CONTENT, { headers: true })
+            .addListener('data', (r: RowMap) => rows.push(r))
+            .on('error', next)
+            .on('end', (count: number) => {
+                assert.deepStrictEqual(rows, expectedRows);
+                next();
+            });
+    });
+});