Remove readable-stream - see #729

amqp-node · Nov 24, 2024 · 3cc6c42 · 3cc6c42
1 parent cddd4a8
commit 3cc6c42
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 68 deletions.
diff --git a/lib/connection.js b/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;
 

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.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": {

diff --git a/test/frame.js b/test/frame.js
@@ -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');
 

diff --git a/test/mux.js b/test/mux.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;

diff --git a/test/util.js b/test/util.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');