Skip to content

Commit ee87587

Browse files
committed
fixup: hwm
1 parent ed7c896 commit ee87587

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

lib/internal/streams/operators.js

+1-7
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,6 @@ module.exports.map = function map(stream, fn, options) {
1515
concurrency = options.concurrency;
1616
}
1717

18-
let highWaterMark = 1;
19-
if (options && Number.isFinite(options.highWaterMark)) {
20-
highWaterMark = options.highWaterMark;
21-
}
22-
highWaterMark = Math.max(0, highWaterMark - concurrency)
23-
2418
let objectMode = stream.readableObjectMode ?? stream.objectMode ?? true;
2519
if (options && typeof options.objectMode === 'boolean') {
2620
objectMode = options.objectMode;
@@ -32,9 +26,9 @@ module.exports.map = function map(stream, fn, options) {
3226

3327
let reading = false;
3428

29+
// TODO: What about hwm?
3530
const ret = new Readable({
3631
objectMode,
37-
highWaterMark,
3832
read () {
3933
if (!reading) {
4034
read();

0 commit comments

Comments
 (0)