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
  1cbe8031_cce3_0270_34d7_1b83f106f5f2["astream()"]
  c4bf8d59_69f9_f8e5_efba_837c20df2360["RunnableSequence"]
  1cbe8031_cce3_0270_34d7_1b83f106f5f2 -->|defined in| c4bf8d59_69f9_f8e5_efba_837c20df2360
  dea85c11_55cc_7027_52b2_ae175ec1a0cc["astream()"]
  dea85c11_55cc_7027_52b2_ae175ec1a0cc -->|calls| 1cbe8031_cce3_0270_34d7_1b83f106f5f2
  6b0af8a6_40de_913f_d715_e591ebb530c1["atransform()"]
  1cbe8031_cce3_0270_34d7_1b83f106f5f2 -->|calls| 6b0af8a6_40de_913f_d715_e591ebb530c1
  dea85c11_55cc_7027_52b2_ae175ec1a0cc["astream()"]
  1cbe8031_cce3_0270_34d7_1b83f106f5f2 -->|calls| dea85c11_55cc_7027_52b2_ae175ec1a0cc
  style 1cbe8031_cce3_0270_34d7_1b83f106f5f2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 3552–3562

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

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