nodejs
diff --git a/‎lib/internal/streams/iter/from.js‎
Lines changed: 9 additions & 4 deletions b/‎lib/internal/streams/iter/from.js‎
Lines changed: 9 additions & 4 deletions
diff --git a/‎test/parallel/test-stream-iter-from-sync.js‎
Lines changed: 27 additions & 1 deletion b/‎test/parallel/test-stream-iter-from-sync.js‎
Lines changed: 27 additions & 1 deletion
@@ -484,15 +484,20 @@ 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)',
       input,
     );
   }
-  if (typeof input === 'object' && input !== null && typeof input.then === 'function') {
+  if (!isIterable &&
+      typeof input === 'object' &&
+      input !== null &&
+      typeof input.then === 'function') {
     throw new ERR_INVALID_ARG_TYPE(
       'input',
       'a synchronous input (not Promise)',
@@ -501,7 +506,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'],
 
@@ -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,30 @@ 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');
+}
+
+function testFromSyncPrefersIteratorForThenableIterable() {
+  const input = {
+    then() {},
+    *[Symbol.iterator]() {
+      yield new TextEncoder().encode('sync');
+    },
+  };
+
+  assert.strictEqual(textSync(fromSync(input)), 'sync');
+}
+
 // Promise rejected
 function testFromSyncRejectsPromise() {
   assert.throws(() => fromSync(Promise.resolve('hello')),
@@ -232,6 +256,8 @@ Promise.all([
   testFromSyncTopLevelProtocolOverIterator(),
   testFromSyncIgnoresAsyncStreamable(),
   testFromSyncRejectsAsyncIterable(),
+  testFromSyncPrefersIteratorForDualIterable(),
+  testFromSyncPrefersIteratorForThenableIterable(),
   testFromSyncRejectsPromise(),
   testFromSyncDataView(),
 ]).then(common.mustCall());