From 8db372341dc60f0757ed6a4d31504cac05117cbc Mon Sep 17 00:00:00 2001
From: Ardis Lu <ardisglu@gmail.com>
Date: Mon, 4 Aug 2025 23:45:11 -0700
Subject: [PATCH] Fix broken test

---
 test/core.test.js | 10 +++++-----
 test/utils.js     |  3 +++
 2 files changed, 8 insertions(+), 5 deletions(-)

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);
     }
   });
 }
-- 
2.47.3