Add test for saving progress on uncaught error

diff --git a/test/core.test.js b/test/core.test.js
index 26bfa606c288ff30de2fbe09a7a3641d4a432732..283939767a49f4a69835cced61baea2f54673d8f 100644 (file)
--- a/test/core.test.js
+++ b/test/core.test.js
@@ -519,6 +519,22 @@ suite('CSVWriter', { concurrency: true }, () => {
         ['row 3', 'c']
       ]));
   });
+  test('flushes progress to disk on uncaught error', { concurrency: true }, async (t) => {
+    const temp = await createTempFile();
+    t.after(async () => await unlink(temp));
+    await rejects(async () => {
+      await ReadableStream.from((function* () {
+        yield '["header1","header2"]';
+        yield '["1","1"]';
+        throw new Error();
+      })()).pipeTo(new CSVWriter(temp))
+    });
+    await new CSVReader(temp).pipeTo(
+      csvStreamEqualWritable([
+        ['header1', 'header2'],
+        ['1', '1'],
+      ]));
+  });
 });
 
 suite('CSVWriter status', { concurrency: true }, () => {