Skip to content

Commit fe7ef1a

Browse files
watildeBridgeAR
authored andcommitted
test: add test for autoDestroy in stream
PR-URL: #24127 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Mathias Buus <mathiasbuus@gmail.com>
1 parent 02e9fa0 commit fe7ef1a

File tree

1 file changed

+28
-0
lines changed

1 file changed

+28
-0
lines changed

test/parallel/test-stream-auto-destroy.js

+28
Original file line numberDiff line numberDiff line change
@@ -82,3 +82,31 @@ const assert = require('assert');
8282
assert(finished);
8383
}));
8484
}
85+
86+
{
87+
const r = new stream.Readable({
88+
read() {
89+
r2.emit('error', new Error('fail'));
90+
}
91+
});
92+
const r2 = new stream.Readable({
93+
autoDestroy: true,
94+
destroy: common.mustCall((err, cb) => cb())
95+
});
96+
97+
r.pipe(r2);
98+
}
99+
100+
{
101+
const r = new stream.Readable({
102+
read() {
103+
w.emit('error', new Error('fail'));
104+
}
105+
});
106+
const w = new stream.Writable({
107+
autoDestroy: true,
108+
destroy: common.mustCall((err, cb) => cb())
109+
});
110+
111+
r.pipe(w);
112+
}

0 commit comments

Comments
 (0)