From cb5d3a518fe0b665dcb7f42a37e46305c566f916 Mon Sep 17 00:00:00 2001 From: Antoine du Hamel Date: Wed, 29 Apr 2026 11:29:12 +0200 Subject: [PATCH] stream: remove unnecessary check Signed-off-by: Antoine du Hamel --- lib/internal/webstreams/util.js | 19 +++++++++---------- 1 file changed, 9 insertions(+), 10 deletions(-) diff --git a/lib/internal/webstreams/util.js b/lib/internal/webstreams/util.js index 81e65815eabe6b..867cf043bee9bf 100644 --- a/lib/internal/webstreams/util.js +++ b/lib/internal/webstreams/util.js @@ -54,12 +54,11 @@ const AsyncIterator = { function extractHighWaterMark(value, defaultHWM) { if (value === undefined) return defaultHWM; - value = +value; - if (typeof value !== 'number' || - NumberIsNaN(value) || - value < 0) + const coercedValue = +value; + if (NumberIsNaN(coercedValue) || + coercedValue < 0) throw new ERR_INVALID_ARG_VALUE.RangeError('strategy.highWaterMark', value); - return value; + return coercedValue; } function extractSizeAlgorithm(size) { @@ -151,13 +150,13 @@ function peekQueueValue(controller) { function enqueueValueWithSize(controller, value, size) { assert(controller[kState].queue !== undefined); assert(controller[kState].queueTotalSize !== undefined); - size = +size; - if (typeof size !== 'number' || - size < 0 || - NumberIsNaN(size) || - size === Infinity) { + const coercedSize = +size; + if (NumberIsNaN(coercedSize) || + coercedSize < 0 || + coercedSize === Infinity) { throw new ERR_INVALID_ARG_VALUE.RangeError('size', size); } + size = coercedSize; ArrayPrototypePush(controller[kState].queue, { value, size }); controller[kState].queueTotalSize += size; }