Merge pull request #777 from amqp-node/remove-readable-stream

Remove readable-stream - see #729

Author: cressie176

lib/connection.js

@@ -10,9 +10,7 @@ var frame = require('./frame');
 var HEARTBEAT = frame.HEARTBEAT;
 var Mux = require('./mux').Mux;
 
-var Duplex =
-  require('stream').Duplex ||
-  require('readable-stream/duplex');
+var Duplex = require('stream').Duplex;
 var EventEmitter = require('events');
 var Heart = require('./heartbeat').Heart;
 
@@ -22,8 +20,7 @@ var inspect = require('./format').inspect;
 
 var BitSet = require('./bitset').BitSet;
 var fmt = require('util').format;
-var PassThrough = require('stream').PassThrough ||
-  require('readable-stream/passthrough');
+var PassThrough = require('stream').PassThrough;
 var IllegalOperationError = require('./error').IllegalOperationError;
 var stackCapture = require('./error').stackCapture;
 

package-lock.json

@@ -14,7 +14,6 @@
   "dependencies": {
     "@acuminous/bitsyntax": "^0.1.2",
     "buffer-more-ints": "~1.0.0",
-    "readable-stream": "1.x >=1.1.9",
     "url-parse": "~1.5.10"
   },
   "devDependencies": {

package.json

@@ -7,8 +7,7 @@ var connection = require('../lib/connection');
 var Frames = connection.Connection;
 var HEARTBEAT = require('../lib/frame').HEARTBEAT;
 var Stream = require('stream');
-var PassThrough = Stream.PassThrough ||
-    require('readable-stream/passthrough');
+var PassThrough = Stream.PassThrough;
 
 var defs = require('../lib/defs');
 

test/frame.js

@@ -2,8 +2,7 @@
 
 var assert = require('assert');
 var Mux = require('../lib/mux').Mux;
-var PassThrough = require('stream').PassThrough ||
-  require('readable-stream/passthrough');
+var PassThrough = require('stream').PassThrough;
 
 var latch = require('./util').latch;
 var schedule = require('./util').schedule;

test/mux.js

@@ -2,9 +2,7 @@
 
 var crypto = require('crypto');
 var Connection = require('../lib/connection').Connection;
-var PassThrough =
-  require('stream').PassThrough ||
-  require('readable-stream/passthrough');
+var PassThrough = require('stream').PassThrough;
 var defs = require('../lib/defs');
 var assert = require('assert');