nodejs
diff --git a/‎lib/internal/streams/iter/broadcast.js‎
Lines changed: 6 additions & 0 deletions b/‎lib/internal/streams/iter/broadcast.js‎
Lines changed: 6 additions & 0 deletions
diff --git a/‎test/parallel/test-stream-iter-validation.js‎
Lines changed: 10 additions & 0 deletions b/‎test/parallel/test-stream-iter-validation.js‎
Lines changed: 10 additions & 0 deletions
@@ -463,6 +463,9 @@ class BroadcastWriter {
   }
 
   writev(chunks, options) {
+    if (!ArrayIsArray(chunks)) {
+      throw new ERR_INVALID_ARG_TYPE('chunks', 'Array', chunks);
+    }
     // Fast path: no signal, writer open, buffer has space
     if (this.#canUseWriteFastPath(options)) {
       const converted = convertChunks(chunks);
@@ -523,6 +526,9 @@ class BroadcastWriter {
   }
 
   writevSync(chunks) {
+    if (!ArrayIsArray(chunks)) {
+      throw new ERR_INVALID_ARG_TYPE('chunks', 'Array', chunks);
+    }
     if (this.#isClosedOrAborted()) return false;
     if (!this.#broadcast[kCanWrite]()) return false;
     const converted = convertChunks(chunks);
 
@@ -147,6 +147,16 @@ assert.throws(() => broadcast({ highWaterMark: Number.MAX_SAFE_INTEGER + 1 }),
 assert.throws(() => broadcast({ signal: {} }), { code: 'ERR_INVALID_ARG_TYPE' });
 assert.throws(() => broadcast({ backpressure: 'bad' }), { code: 'ERR_INVALID_ARG_VALUE' });
 
+// BroadcastWriter.writev requires array
+{
+  const { writer } = broadcast();
+  assert.throws(() => writer.writev('bad'), { code: 'ERR_INVALID_ARG_TYPE' });
+  assert.throws(() => writer.writev(42), { code: 'ERR_INVALID_ARG_TYPE' });
+  assert.throws(() => writer.writevSync('bad'), { code: 'ERR_INVALID_ARG_TYPE' });
+  assert.throws(() => writer.writevSync(42), { code: 'ERR_INVALID_ARG_TYPE' });
+  writer.endSync();
+}
+
 // Broadcast.from rejects non-iterable input
 assert.throws(() => Broadcast.from(42), { code: 'ERR_INVALID_ARG_TYPE' });
 assert.throws(() => Broadcast.from('bad'), { code: 'ERR_INVALID_ARG_TYPE' });