Add header row deletion test

diff --git a/test/core.test.js b/test/core.test.js
index 52aba74fe3b1a4232cc19e9fbf5caa0c2185f778..b0645098cd192e2067415ec323b6304ac551ce73 100644 (file)
--- a/test/core.test.js
+++ b/test/core.test.js
@@ -274,6 +274,16 @@ suite('CSVTransformer', { concurrency: true }, () => {
         ['1', '2']
       ]));
   });
+  test('deletes header row when handleHeaders returns null', { concurrency: true }, async () => {
+    await createCSVMockStream([
+      ['a', 'b'],
+      ['1', '2']
+    ])
+      .pipeThrough(new CSVTransformer(r => r, { handleHeaders: () => null }))
+      .pipeTo(csvStreamEqualWritable([
+        ['1', '2']
+      ]));
+  });
   test('enqueues multiple rows when Array<Array<any>> is returned', { concurrency: true }, async () => {
     await createCSVMockStream([
       ['columnA', 'columnB'],