Add test for handleHeaders error handling

diff --git a/test/core.test.js b/test/core.test.js
index 9418c38239d816402e10074a5de7def3e78027d1..3ff4edba784cf0573b92f4171ba6be65e01322b5 100644 (file)
--- a/test/core.test.js
+++ b/test/core.test.js
@@ -312,6 +312,19 @@ suite('CSVTransformer', { concurrency: true }, () => {
         ['2: caught']
       ]));
   });
+  test('passes handleHeaders to onError if handleHeaders is a function', { concurrency: true }, async () => {
+    await createCSVMockStream([
+      ['columnA'],
+      ['1'],
+      ['2']
+    ])
+      .pipeThrough(new CSVTransformer(r => r, { handleHeaders: () => { throw new Error() }, onError: r => [`${r[0]}: caught`] }))
+      .pipeTo(csvStreamEqualWritable([
+        ['columnA: caught'],
+        ['1'],
+        ['2']
+      ]));
+  });
   test('bubbles up errors re-raised by onError function', { concurrency: true }, async () => {
     await rejects(
       createCSVMockStream([