From: Ardis Lu <ardisglu@gmail.com>
Date: Tue, 5 Aug 2025 06:45:11 +0000 (-0700)
Subject: Fix broken test
X-Git-Tag: v0.1.5~10
X-Git-Url: https://git.ardis.lu/?a=commitdiff_plain;h=8db372341dc60f0757ed6a4d31504cac05117cbc;p=csvio

Fix broken test
---

diff --git a/test/core.test.js b/test/core.test.js
index e549962..76bb9ac 100644
--- 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 948bfbc..71dcc71 100644
--- 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);
     }
   });
 }