stream: prefer sync iterator in fromSync

When an input provides both Symbol.iterator and Symbol.asyncIterator,
fromSync() should consume the synchronous iterator instead of rejecting
the input as async.

Signed-off-by: Kamat, Trivikram <16024985+trivikr@users.noreply.github.com>
Assisted-by: openai:gpt-5.5

Author: trivikr

lib/internal/streams/iter/from.js

@@ -484,8 +484,10 @@ function fromSync(input) {
     return fromSync(input[toStreamable]());
   }
 
-  // Reject explicit async inputs
-  if (isAsyncIterable(input)) {
+  const isIterable = isSyncIterable(input);
+
+  // Reject explicit async-only inputs
+  if (!isIterable && isAsyncIterable(input)) {
     throw new ERR_INVALID_ARG_TYPE(
       'input',
       'a synchronous input (not AsyncIterable)',
@@ -501,7 +503,7 @@ function fromSync(input) {
   }
 
   // Must be a SyncStreamable
-  if (!isSyncIterable(input)) {
+  if (!isIterable) {
     throw new ERR_INVALID_ARG_TYPE(
       'input',
       ['string', 'ArrayBuffer', 'ArrayBufferView', 'Iterable', 'toStreamable'],

test/parallel/test-stream-iter-from-sync.js

@@ -3,7 +3,7 @@
 
 const common = require('../common');
 const assert = require('assert');
-const { fromSync } = require('stream/iter');
+const { fromSync, textSync } = require('stream/iter');
 
 function testFromSyncString() {
   // String input should be UTF-8 encoded
@@ -186,6 +186,19 @@ function testFromSyncRejectsAsyncIterable() {
   assert.throws(() => fromSync(gen()), { code: 'ERR_INVALID_ARG_TYPE' });
 }
 
+function testFromSyncPrefersIteratorForDualIterable() {
+  const input = {
+    *[Symbol.iterator]() {
+      yield new TextEncoder().encode('sync');
+    },
+    async *[Symbol.asyncIterator]() {
+      yield new TextEncoder().encode('async');
+    },
+  };
+
+  assert.strictEqual(textSync(fromSync(input)), 'sync');
+}
+
 // Promise rejected
 function testFromSyncRejectsPromise() {
   assert.throws(() => fromSync(Promise.resolve('hello')),
@@ -232,6 +245,7 @@ Promise.all([
   testFromSyncTopLevelProtocolOverIterator(),
   testFromSyncIgnoresAsyncStreamable(),
   testFromSyncRejectsAsyncIterable(),
+  testFromSyncPrefersIteratorForDualIterable(),
   testFromSyncRejectsPromise(),
   testFromSyncDataView(),
 ]).then(common.mustCall());