fixup: hwm

nodejs · Nov 17, 2021 · ee87587 · ee87587
1 parent ed7c896
commit ee87587
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/lib/internal/streams/operators.js b/lib/internal/streams/operators.js
@@ -15,12 +15,6 @@ module.exports.map = function map(stream, fn, options) {
     concurrency = options.concurrency;
   }
 
-  let highWaterMark = 1;
-  if (options && Number.isFinite(options.highWaterMark)) {
-    highWaterMark = options.highWaterMark;
-  }
-  highWaterMark = Math.max(0, highWaterMark - concurrency)
-
   let objectMode = stream.readableObjectMode ?? stream.objectMode ?? true;
   if (options && typeof options.objectMode === 'boolean') {
     objectMode = options.objectMode;
@@ -32,9 +26,9 @@ module.exports.map = function map(stream, fn, options) {
 
   let reading = false;
 
+  // TODO: What about hwm?
   const ret = new Readable({
     objectMode,
-    highWaterMark,
     read () {
       if (!reading) {
         read();