nodejs
diff --git a/Collapse file
‎lib/internal/webstreams/readablestream.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/readablestream.js
+3Lines changed: 3 additions & 0 deletions b/Collapse file
‎lib/internal/webstreams/readablestream.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/readablestream.js
+3Lines changed: 3 additions & 0 deletions
diff --git a/Collapse file
‎test/parallel/test-webstream-readable-from.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-webstream-readable-from.js
+19Lines changed: 19 additions & 0 deletions b/Collapse file
‎test/parallel/test-webstream-readable-from.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-webstream-readable-from.js
+19Lines changed: 19 additions & 0 deletions
@@ -1365,6 +1365,9 @@ function readableStreamFromIterable(iterable) {
     throw new ERR_ARG_NOT_ITERABLE(iterable);
   }
   const iterator = FunctionPrototypeCall(iteratorGetter, iterable);
+  if (iterator === null || (typeof iterator !== 'object' && typeof iterator !== 'function')) {
+    throw new ERR_INVALID_STATE.TypeError('The iterator method must return an object');
+  }
   const startAlgorithm = nonOpStart;
 
   async function pullAlgorithm() {
 
@@ -7,3 +7,22 @@ assert.throws(
   () => ReadableStream.from({}),
   { code: 'ERR_ARG_NOT_ITERABLE', name: 'TypeError' },
 );
+
+const invalidIterators = [
+  { [Symbol.iterator]: () => 42 },
+  { [Symbol.asyncIterator]: () => 42 },
+];
+
+for (const iterable of invalidIterators) {
+  assert.throws(
+    () => ReadableStream.from(iterable),
+    { code: 'ERR_INVALID_STATE', name: 'TypeError' },
+  );
+}
+
+function functionIterator() {}
+
+// doesNotThrow
+ReadableStream.from({
+  [Symbol.iterator]: () => functionIterator,
+});