nodejs
diff --git a/‎lib/internal/streams/iter/utils.js‎
Lines changed: 3 additions & 4 deletions b/‎lib/internal/streams/iter/utils.js‎
Lines changed: 3 additions & 4 deletions
diff --git a/‎test/parallel/test-stream-iter-push-writer.js‎
Lines changed: 23 additions & 0 deletions b/‎test/parallel/test-stream-iter-push-writer.js‎
Lines changed: 23 additions & 0 deletions
@@ -190,15 +190,14 @@ function toUint8Array(chunk) {
 }
 
 /**
- * Check if all chunks in an array are already Uint8Array (no strings).
- * Short-circuits on the first string found.
+ * Check if all chunks in an array are already Uint8Array.
+ * Short-circuits on the first non-Uint8Array chunk found.
  * @param {Array<Uint8Array|string>} chunks
  * @returns {boolean}
  */
 function allUint8Array(chunks) {
-  // Ok, well, kind of. This is more a check for "no strings"...
   for (let i = 0; i < chunks.length; i++) {
-    if (typeof chunks[i] === 'string') return false;
+    if (!isUint8Array(chunks[i])) return false;
   }
   return true;
 }
 
@@ -171,6 +171,28 @@ async function testWritevSync() {
   assert.strictEqual(result, 'hello');
 }
 
+async function testWritevSyncInvalidChunkDoesNotQueue() {
+  const { writer, readable } = push({ highWaterMark: 10 });
+
+  assert.throws(
+    () => writer.writevSync([1]),
+    { code: 'ERR_INVALID_ARG_TYPE' },
+  );
+
+  const iter = readable[Symbol.asyncIterator]();
+  const next = iter.next();
+  const result = await Promise.race([
+    next.then(() => 'resolved'),
+    new Promise((resolve) => setImmediate(resolve, 'pending')),
+  ]);
+  assert.strictEqual(result, 'pending');
+
+  writer.endSync();
+  const end = await next;
+  assert.strictEqual(end.value, undefined);
+  assert.strictEqual(end.done, true);
+}
+
 async function testWritevMixedTypes() {
   const { writer, readable } = push({ highWaterMark: 10 });
   // Mix strings and Uint8Arrays
@@ -494,6 +516,7 @@ Promise.all([
   testOndrainRejectsOnConsumerThrow(),
   testWritev(),
   testWritevSync(),
+  testWritevSyncInvalidChunkDoesNotQueue(),
   testWritevMixedTypes(),
   testWriteAfterEnd(),
   testWriteAfterFail(),
Original file line number	Diff line number	Diff line change
`@@ -190,15 +190,14 @@ function toUint8Array(chunk) {`
`190`	`190`	`}`
`191`	`191`
`192`	`192`	`/**`
`193`		`- * Check if all chunks in an array are already Uint8Array (no strings).`
`194`		`- * Short-circuits on the first string found.`
	`193`	`+ * Check if all chunks in an array are already Uint8Array.`
	`194`	`+ * Short-circuits on the first non-Uint8Array chunk found.`
`195`	`195`	`* @param {Array<Uint8Array\|string>} chunks`
`196`	`196`	`* @returns {boolean}`
`197`	`197`	`*/`
`198`	`198`	`function allUint8Array(chunks) {`
`199`		`- // Ok, well, kind of. This is more a check for "no strings"...`
`200`	`199`	`for (let i = 0; i < chunks.length; i++) {`
`201`		`- if (typeof chunks[i] === 'string') return false;`
	`200`	`+ if (!isUint8Array(chunks[i])) return false;`
`202`	`201`	`}`
`203`	`202`	`return true;`
`204`	`203`	`}`