diff --git a/index.js b/index.js index a3f768e..b5cbccb 100644 --- a/index.js +++ b/index.js @@ -2,7 +2,7 @@ const metadata = Symbol.for('pino.metadata') const split = require('split2') -const duplexify = require('duplexify') +const { Duplex } = require('readable-stream') module.exports = function build (fn, opts = {}) { const parseLines = opts.parse === 'lines' @@ -67,9 +67,7 @@ module.exports = function build (fn, opts = {}) { // set it to null to not retain a reference to the promise res = null } else if (opts.enablePipelining && res) { - return duplexify(stream, res, { - objectMode: true - }) + return Duplex.from({ writable: stream, readable: res, objectMode: true }) } return stream diff --git a/package.json b/package.json index a25be27..5cf39f2 100644 --- a/package.json +++ b/package.json @@ -23,7 +23,7 @@ }, "homepage": "https://github.com/pinojs/pino-abstract-transport#readme", "dependencies": { - "duplexify": "^4.1.2", + "readable-stream": "^4.0.0", "split2": "^4.0.0" }, "devDependencies": {