diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js index 7e87210a774..1178108842b 100644 --- a/lib/internal/streams/pipeline.js +++ b/lib/internal/streams/pipeline.js @@ -3,7 +3,7 @@ 'use strict'; -const eos = require('internal/streams/end-of-stream'); +let eos; const { ERR_MISSING_ARGS, @@ -33,6 +33,7 @@ function destroyer(stream, reading, writing, callback) { closed = true; }); + if (eos === undefined) eos = require('internal/streams/end-of-stream'); eos(stream, { readable: reading, writable: writing }, (err) => { if (err) return callback(err); closed = true;