feat: drop readable-stream (moscajs#724)

chfritz · Feb 3, 2025 · 593e2ec · 593e2ec
1 parent 9d2dbb2
commit 593e2ec
Show file tree

Hide file tree

Showing 5 changed files with 4 additions and 5 deletions.
diff --git a/aedes.js b/aedes.js
@@ -7,7 +7,7 @@ const series = require('fastseries')
 const { v4: uuidv4 } = require('uuid')
 const bulk = require('bulk-write-stream')
 const reusify = require('reusify')
-const { pipeline } = require('readable-stream')
+const { pipeline } = require('stream')
 const Packet = require('aedes-packet')
 const memory = require('aedes-persistence')
 const mqemitter = require('mqemitter')

diff --git a/lib/client.js b/lib/client.js
@@ -10,7 +10,7 @@ const QoSPacket = require('./qos-packet')
 const handleSubscribe = require('./handlers/subscribe')
 const handleUnsubscribe = require('./handlers/unsubscribe')
 const handle = require('./handlers')
-const { pipeline } = require('readable-stream')
+const { pipeline } = require('stream')
 const { through } = require('./utils')
 
 module.exports = Client

diff --git a/lib/handlers/connect.js b/lib/handlers/connect.js
@@ -1,7 +1,7 @@
 'use strict'
 
 const retimer = require('retimer')
-const { pipeline } = require('readable-stream')
+const { pipeline } = require('stream')
 const write = require('../write')
 const QoSPacket = require('../qos-packet')
 const { through } = require('../utils')

diff --git a/lib/utils.js b/lib/utils.js
@@ -1,6 +1,6 @@
 'use strict'
 
-const { Transform } = require('readable-stream')
+const { Transform } = require('stream')
 
 function validateTopic (topic, message) {
   const end = topic.length - 1

diff --git a/package.json b/package.json
@@ -128,7 +128,6 @@
     "hyperid": "^3.0.0",
     "mqemitter": "^4.5.0",
     "mqtt-packet": "^7.1.2",
-    "readable-stream": "^3.6.0",
     "retimer": "^3.0.0",
     "reusify": "^1.0.4",
     "uuid": "^8.3.2"