Skip to content

Commit cb5d3a5

Browse files
committed
stream: remove unnecessary check
Signed-off-by: Antoine du Hamel <[email protected]>
1 parent 1f9636a commit cb5d3a5

1 file changed

Lines changed: 9 additions & 10 deletions

File tree

lib/internal/webstreams/util.js

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -54,12 +54,11 @@ const AsyncIterator = {
5454

5555
function extractHighWaterMark(value, defaultHWM) {
5656
if (value === undefined) return defaultHWM;
57-
value = +value;
58-
if (typeof value !== 'number' ||
59-
NumberIsNaN(value) ||
60-
value < 0)
57+
const coercedValue = +value;
58+
if (NumberIsNaN(coercedValue) ||
59+
coercedValue < 0)
6160
throw new ERR_INVALID_ARG_VALUE.RangeError('strategy.highWaterMark', value);
62-
return value;
61+
return coercedValue;
6362
}
6463

6564
function extractSizeAlgorithm(size) {
@@ -151,13 +150,13 @@ function peekQueueValue(controller) {
151150
function enqueueValueWithSize(controller, value, size) {
152151
assert(controller[kState].queue !== undefined);
153152
assert(controller[kState].queueTotalSize !== undefined);
154-
size = +size;
155-
if (typeof size !== 'number' ||
156-
size < 0 ||
157-
NumberIsNaN(size) ||
158-
size === Infinity) {
153+
const coercedSize = +size;
154+
if (NumberIsNaN(coercedSize) ||
155+
coercedSize < 0 ||
156+
coercedSize === Infinity) {
159157
throw new ERR_INVALID_ARG_VALUE.RangeError('size', size);
160158
}
159+
size = coercedSize;
161160
ArrayPrototypePush(controller[kState].queue, { value, size });
162161
controller[kState].queueTotalSize += size;
163162
}

0 commit comments

Comments
 (0)