diff --git a/test/parallel/test-stream-finished.js b/test/parallel/test-stream-finished.js index d1652396dae25d..43b1e36a547402 100644 --- a/test/parallel/test-stream-finished.js +++ b/test/parallel/test-stream-finished.js @@ -553,14 +553,14 @@ testClosed((opts) => new Writable({ write() {}, ...opts })); } { - const server = http.createServer((req, res) => { - res.on('close', () => { + const server = http.createServer(common.mustCall((req, res) => { + res.on('close', common.mustCall(() => { finished(res, common.mustCall(() => { server.close(); })); - }); + })); res.end(); - }) + })) .listen(0, function() { http.request({ method: 'GET', @@ -570,6 +570,22 @@ testClosed((opts) => new Writable({ write() {}, ...opts })); }); } +{ + const server = http.createServer(common.mustCall((req, res) => { + req.on('close', common.mustCall(() => { + finished(req, common.mustCall(() => { + server.close(); + })); + })); + req.destroy(); + })).listen(0, function() { + http.request({ + method: 'GET', + port: this.address().port + }).end().on('error', common.mustCall()); + }); +} + { const w = new Writable({