Fix broken test

diff --git a/test/core.test.js b/test/core.test.js
index e549962821515bff0e0e7be0186df3bdcb08b6ea..76bb9ac779ded295b3f4a8246bd4a45f5975c6f4 100644 (file)
--- a/test/core.test.js
+++ b/test/core.test.js
@@ -338,15 +338,15 @@ suite('CSVTransformer', { concurrency: true }, () => {
   test('consumes input row without output row when null is returned', { concurrency: true }, async () => {
     await createCSVMockStream([
       ['columnA', 'columnB'],
-      ['should be deleted', 'should be deleted'],
+      ['delete'],
       ['a', 'b'],
-      ['should be deleted', 'should be deleted'],
+      ['delete'],
       ['a', 'b'],
-      ['should be deleted', 'should be deleted'],
+      ['delete'],
       ['a', 'b'],
-      ['should be deleted', 'should be deleted']
+      ['delete']
     ])
-      .pipeThrough(new CSVTransformer(r => r.length % 2 ? r : null))
+      .pipeThrough(new CSVTransformer(r => r[0] === 'delete' ? null : r))
       .pipeTo(csvStreamEqualWritable([
         ['columnA', 'columnB'],
         ['a', 'b'],

diff --git a/test/utils.js b/test/utils.js
index 948bfbc0eed8c3f3ec2a050a392012aef2518afc..71dcc71b4fbfd191dbe2905163aafc414c72275f 100644 (file)
--- a/test/utils.js
+++ b/test/utils.js
@@ -24,6 +24,9 @@ export function csvStreamEqualWritable(csv) {
         deepStrictEqual(chunk[j], csv[i][j]);
       }
       i++;
+    },
+    close() {
+      deepStrictEqual(i, csv.length);
     }
   });
 }