Function _aiter_from_iter

src/google/adk/cli/fast_api.py:917–923

(iterator)

      if inspect.isgenerator(output):

        async def _aiter_from_iter(iterator):
          while True:
            try:
              chunk = await run_in_threadpool(next, iterator)
              yield chunk
            except StopIteration:
              break

        content_iter = _aiter_from_iter(output)
      else: