aboutsummaryrefslogtreecommitdiff
path: root/test/js/node/stream/node-stream.test.js
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--test/js/node/stream/node-stream.test.js26
1 files changed, 26 insertions, 0 deletions
diff --git a/test/js/node/stream/node-stream.test.js b/test/js/node/stream/node-stream.test.js
index 51252a5f6..5f5b9d67a 100644
--- a/test/js/node/stream/node-stream.test.js
+++ b/test/js/node/stream/node-stream.test.js
@@ -41,6 +41,32 @@ describe("Readable", () => {
readable.pipe(writable);
});
+ it("should be able to be piped via .pipe, issue #3607", done => {
+ const path = `${tmpdir()}/${Date.now()}.testReadStreamEmptyFile.txt`;
+ writeFileSync(path, "");
+ const stream = createReadStream(path);
+ stream.on("error", err => {
+ done(err);
+ });
+
+ let called = false;
+ const writable = new Writable({
+ write(chunk, encoding, callback) {
+ called = true;
+ callback();
+ },
+ });
+ writable.on("finish", () => {
+ try {
+ expect(called).toBeFalse();
+ } catch (err) {
+ return done(err);
+ }
+ done();
+ });
+
+ stream.pipe(writable);
+ });
it("should be able to be piped via .pipe, issue #3668", done => {
const path = `${tmpdir()}/${Date.now()}.testReadStream.txt`;
writeFileSync(path, "12345");