Function json_generator

src/google/adk/cli/fast_api.py:797–802

(output: AsyncIterator[Any])

        return None

    async def json_generator(output: AsyncIterator[Any]) -> AsyncIterator[str]:
      async for chunk in output:
        encoded_chunk = _encode_chunk_to_json(chunk)
        if encoded_chunk is None:
          break
        yield encoded_chunk

    async def _invoke_callable_or_raise(
        invocation_callable: Callable[..., Any],