diff options
Diffstat (limited to 'tests/js/hero.mjs')
-rw-r--r-- | tests/js/hero.mjs | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/tests/js/hero.mjs b/tests/js/hero.mjs index 67cf690..14d9a07 100644 --- a/tests/js/hero.mjs +++ b/tests/js/hero.mjs @@ -1378,6 +1378,12 @@ const test_makePipeReaderFn = async t => { const lines = []; const lineFn = x => lines.push(x); const makePipeReader = makePipeReaderFn({ lineFn: null }); + + rmIf(path); + makePipeReader(path); + fs.createWriteStream(path).end(); + + assert.deepEqual(lines, []); }); await t.test("closing on pipe EOF reopens", async () => { @@ -1385,6 +1391,21 @@ const test_makePipeReaderFn = async t => { const lines = []; const lineFn = x => lines.push(x); const makePipeReader = makePipeReaderFn({ lineFn }); + + rmIf(path); + makePipeReader(path); + const writer = fs.createWriteStream(path); + writer.end("first\nsecond\nthird\n"); + return new Promise((resolve, reject) => { + writer.close(() => { + assert.deepEqual(lines, [ + "first", + "second", + "third", + ]); + resolve(); + }); + }); }); }; |