Skip to content

Commit 75ad480

Browse files
committed
fixup
1 parent 97ee87b commit 75ad480

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

test/parallel/test-stream-pipeline.js

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1245,7 +1245,8 @@ const net = require('net');
12451245
'ENOENT: no such file or directory, ' +
12461246
'open \'./notfound\'');
12471247
res.end(err.message);
1248-
}));
1248+
});
1249+
pipeline(r, transform, res, { destroyDestOnError: false }, callback);
12491250
}));
12501251

12511252
server.listen(0, common.mustCall(() => {
@@ -1273,7 +1274,7 @@ const net = require('net');
12731274
const server = http.createServer(common.mustCall((req, res) => {
12741275
const r = fs.createReadStream('./notfound');
12751276
const transform = new PassThrough();
1276-
pipeline(r, transform, res, { destroyDestOnError: false }, common.mustCall((err) => {
1277+
const callback = common.mustCall((err) => {
12771278
assert.ok(!res.destroyed);
12781279
assert.ok(r.destroyed);
12791280
assert.ok(transform.destroyed);

0 commit comments

Comments
 (0)