summaryrefslogtreecommitdiff
path: root/tests/js/hero.mjs
diff options
context:
space:
mode:
Diffstat (limited to 'tests/js/hero.mjs')
-rw-r--r--tests/js/hero.mjs21
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();
+ });
+ });
});
};