agenerate_from_stream() — langchain Function Reference

Architecture documentation for the agenerate_from_stream() function in chat_models.py from the langchain codebase.

Function python CoreAbstractions MessageSchema

Entity Profile

CoreAbstractions→ MessageSchema→ agenerate_from_stream() — langchain Function Reference

Dependency Diagram

graph TD
  bfde952e_83b5_5327_2057_9dff6c37585e["agenerate_from_stream()"]
  20f4116a_d26d_2a5f_4a10_67af6940e081["chat_models.py"]
  bfde952e_83b5_5327_2057_9dff6c37585e -->|defined in| 20f4116a_d26d_2a5f_4a10_67af6940e081
  style bfde952e_83b5_5327_2057_9dff6c37585e fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/language_models/chat_models.py lines 211–224

async def agenerate_from_stream(
    stream: AsyncIterator[ChatGenerationChunk],
) -> ChatResult:
    """Async generate from a stream.

    Args:
        stream: Iterator of `ChatGenerationChunk`.

    Returns:
        Chat result.

    """
    chunks = [chunk async for chunk in stream]
    return await run_in_executor(None, generate_from_stream, iter(chunks))