astream() — langchain Function Reference

Architecture documentation for the astream() function in base.py from the langchain codebase.

Function python LangChainCore Runnables calls 2 called by 1

Entity Profile

LangChainCore→ Runnables→ astream() — langchain Function Reference

Dependency Diagram

graph TD
  521ad83e_0c69_b97d_0d8e_466b6e030ed2["astream()"]
  17599172_8889_afc6_2237_4429f3439071["RunnableParallel"]
  521ad83e_0c69_b97d_0d8e_466b6e030ed2 -->|defined in| 17599172_8889_afc6_2237_4429f3439071
  c72cfdff_e918_26c0_491d_f2427709f589["astream()"]
  c72cfdff_e918_26c0_491d_f2427709f589 -->|calls| 521ad83e_0c69_b97d_0d8e_466b6e030ed2
  dd47e0f6_01d1_bac7_e0fb_611561853fa8["atransform()"]
  521ad83e_0c69_b97d_0d8e_466b6e030ed2 -->|calls| dd47e0f6_01d1_bac7_e0fb_611561853fa8
  c72cfdff_e918_26c0_491d_f2427709f589["astream()"]
  521ad83e_0c69_b97d_0d8e_466b6e030ed2 -->|calls| c72cfdff_e918_26c0_491d_f2427709f589
  style 521ad83e_0c69_b97d_0d8e_466b6e030ed2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 4079–4089

    async def astream(
        self,
        input: Input,
        config: RunnableConfig | None = None,
        **kwargs: Any | None,
    ) -> AsyncIterator[dict[str, Any]]:
        async def input_aiter() -> AsyncIterator[Input]:
            yield input

        async for chunk in self.atransform(input_aiter(), config):
            yield chunk