nodejs
diff --git a/‎lib/internal/streams/iter/broadcast.js‎
Lines changed: 1 addition & 1 deletion b/‎lib/internal/streams/iter/broadcast.js‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎test/parallel/test-stream-iter-broadcast-backpressure.js‎
Lines changed: 23 additions & 0 deletions b/‎test/parallel/test-stream-iter-broadcast-backpressure.js‎
Lines changed: 23 additions & 0 deletions
@@ -591,7 +591,7 @@ class BroadcastWriter {
 
     if (policy === 'strict') {
       if (this.#pendingWrites.length >= 1) {
-        throw new ERR_INVALID_STATE.TypeError(
+        throw new ERR_INVALID_STATE.RangeError(
           'Backpressure violation: too many pending writes. ' +
           'Await each write() call to respect backpressure.');
       }
 
@@ -113,6 +113,28 @@ async function testBlockBackpressureContent() {
   assert.strictEqual(done.done, true);
 }
 
+async function testStrictBackpressureOverflow() {
+  const { writer } = broadcast({
+    budget: 16384,
+    backpressure: 'strict',
+  });
+
+  await writer.write(new Uint8Array(16384));
+  const pending = writer.write('b');
+
+  await assert.rejects(writer.write('c'), {
+    name: 'RangeError',
+    code: 'ERR_INVALID_STATE',
+  });
+
+  writer.fail();
+  await assert.rejects(pending, {
+    name: 'TypeError',
+    code: 'ERR_INVALID_STATE',
+    message: 'Invalid state: Failed',
+  });
+}
+
 // Writev async path
 async function testWritevAsync() {
   const { writer, broadcast: bc } = broadcast({ budget: 16384 });
@@ -141,6 +163,7 @@ Promise.all([
   testDropNewest(),
   testBlockBackpressure(),
   testBlockBackpressureContent(),
+  testStrictBackpressureOverflow(),
   testWritevAsync(),
   testEndSyncReturnValue(),
 ]).then(common.mustCall());
Original file line number	Diff line number	Diff line change
@@ -591,7 +591,7 @@ class BroadcastWriter {
591	591
592	592	if (policy === 'strict') {
593	593	if (this.#pendingWrites.length >= 1) {
594		- throw new ERR_INVALID_STATE.TypeError(
	594	+ throw new ERR_INVALID_STATE.RangeError(
595	595	'Backpressure violation: too many pending writes. ' +
596	596	'Await each write() call to respect backpressure.');
597	597	}