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	}