astream() — langchain Function Reference

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

Function python LangChainCore Runnables calls 3 called by 2

Entity Profile

LangChainCore→ Runnables→ astream() — langchain Function Reference

Dependency Diagram

graph TD
  29e5a61e_3192_fcb1_8408_ac325ae0e3cd["astream()"]
  e893b6ae_1c28_41f1_aa8b_a66d0f779312["RunnableAssign"]
  29e5a61e_3192_fcb1_8408_ac325ae0e3cd -->|defined in| e893b6ae_1c28_41f1_aa8b_a66d0f779312
  89892239_3bd4_deee_84cd_ee93929f64ad["astream()"]
  89892239_3bd4_deee_84cd_ee93929f64ad -->|calls| 29e5a61e_3192_fcb1_8408_ac325ae0e3cd
  62530ed9_3d20_a587_0e13_a04ed805b3c4["astream()"]
  62530ed9_3d20_a587_0e13_a04ed805b3c4 -->|calls| 29e5a61e_3192_fcb1_8408_ac325ae0e3cd
  eb798efb_a553_9e1b_0bc9_415bcf874209["atransform()"]
  29e5a61e_3192_fcb1_8408_ac325ae0e3cd -->|calls| eb798efb_a553_9e1b_0bc9_415bcf874209
  89892239_3bd4_deee_84cd_ee93929f64ad["astream()"]
  29e5a61e_3192_fcb1_8408_ac325ae0e3cd -->|calls| 89892239_3bd4_deee_84cd_ee93929f64ad
  68f322b4_1349_271a_408d_e2eb04ed643e["atransform()"]
  29e5a61e_3192_fcb1_8408_ac325ae0e3cd -->|calls| 68f322b4_1349_271a_408d_e2eb04ed643e
  style 29e5a61e_3192_fcb1_8408_ac325ae0e3cd fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/passthrough.py lines 658–668

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

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