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
  15baef27_1ae6_bb17_544d_cf6d5de2570c["astream()"]
  9a777f9f_fc96_a4c7_ebd5_632b655b53ae["RunnableBindingBase"]
  15baef27_1ae6_bb17_544d_cf6d5de2570c -->|defined in| 9a777f9f_fc96_a4c7_ebd5_632b655b53ae
  d04ee734_b887_f11d_7551_064b5b024357["astream()"]
  d04ee734_b887_f11d_7551_064b5b024357 -->|calls| 15baef27_1ae6_bb17_544d_cf6d5de2570c
  ff1cc135_559f_c237_6539_8d8ba268c8e8["_merge_configs()"]
  15baef27_1ae6_bb17_544d_cf6d5de2570c -->|calls| ff1cc135_559f_c237_6539_8d8ba268c8e8
  d04ee734_b887_f11d_7551_064b5b024357["astream()"]
  15baef27_1ae6_bb17_544d_cf6d5de2570c -->|calls| d04ee734_b887_f11d_7551_064b5b024357
  style 15baef27_1ae6_bb17_544d_cf6d5de2570c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 5879–5890

    async def astream(
        self,
        input: Input,
        config: RunnableConfig | None = None,
        **kwargs: Any | None,
    ) -> AsyncIterator[Output]:
        async for item in self.bound.astream(
            input,
            self._merge_configs(config),
            **{**self.kwargs, **kwargs},
        ):
            yield item