Use 'readable-stream' instead of 'stream'

bin/pub.js

@@ -7,7 +7,7 @@ var pump = require('pump')
 var path = require('path')
 var fs = require('fs')
 var concat = require('concat-stream')
-var Writable = require('stream').Writable
+var Writable = require('readable-stream').Writable
 var helpMe = require('help-me')({
   dir: path.join(__dirname, '..', 'doc')
 })

lib/client.js

@@ -6,7 +6,7 @@
 var EventEmitter = require('events').EventEmitter
 var Store = require('./store')
 var mqttPacket = require('mqtt-packet')
-var Writable = require('stream').Writable
+var Writable = require('readable-stream').Writable
 var inherits = require('inherits')
 var reInterval = require('reinterval')
 var validations = require('./validations')

lib/connect/ali.js

@@ -1,6 +1,6 @@
 'use strict'
 
-var Transform = require('stream').Transform
+var Transform = require('readable-stream').Transform
 var duplexify = require('duplexify')
 
 /* global FileReader */

lib/connect/ws.js

@@ -4,7 +4,7 @@ const WS = require('ws')
 const debug = require('debug')('mqttjs:ws')
 const duplexify = require('duplexify')
 const urlModule = require('url')
-const Transform = require('stream').Transform
+const Transform = require('readable-stream').Transform
 
 let WSS_OPTIONS = [
   'rejectUnauthorized',

lib/connect/wx.js

@@ -1,6 +1,6 @@
 'use strict'
 
-var Transform = require('stream').Transform
+var Transform = require('readable-stream').Transform
 var duplexify = require('duplexify')
 
 /* global wx */

lib/store.js

@@ -5,7 +5,7 @@
  */
 var xtend = require('xtend')
 
-var Readable = require('stream').Readable
+var Readable = require('readable-stream').Readable
 var streamsOpts = { objectMode: true }
 var defaultStoreOptions = {
   clean: true

package.json

@@ -70,6 +70,7 @@
     "minimist": "^1.2.5",
     "mqtt-packet": "^6.3.2",
     "pump": "^3.0.0",
+    "readable-stream": "^3.6.0",
     "reinterval": "^1.1.0",
     "split2": "^3.1.0",
     "ws": "^7.3.1",

test/client.js

@@ -8,7 +8,7 @@ var abstractClientTests = require('./abstract_client')
 var net = require('net')
 var eos = require('end-of-stream')
 var mqttPacket = require('mqtt-packet')
-var Duplex = require('stream').Duplex
+var Duplex = require('readable-stream').Duplex
 var Connection = require('mqtt-connection')
 var MqttServer = require('./server').MqttServer
 var util = require('util')

test/util.js

@@ -1,6 +1,6 @@
 'use strict'
 
-var Transform = require('stream').Transform
+var Transform = require('readable-stream').Transform
 
 module.exports.testStream = function () {
   return new Transform({