astream_events() — langchain Function Reference

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

Function python LangChainCore Runnables calls 2 called by 2

Entity Profile

LangChainCore→ Runnables→ astream_events() — langchain Function Reference

Dependency Diagram

graph TD
  587028d9_69c4_7ed8_45fe_d86e3f085696["astream_events()"]
  9a777f9f_fc96_a4c7_ebd5_632b655b53ae["RunnableBindingBase"]
  587028d9_69c4_7ed8_45fe_d86e3f085696 -->|defined in| 9a777f9f_fc96_a4c7_ebd5_632b655b53ae
  67cad9a2_ee89_d44e_40ab_e55a36396c0d["astream_events()"]
  67cad9a2_ee89_d44e_40ab_e55a36396c0d -->|calls| 587028d9_69c4_7ed8_45fe_d86e3f085696
  5a7343ac_4a18_f6fb_60ba_828186f81b91["astream_events()"]
  5a7343ac_4a18_f6fb_60ba_828186f81b91 -->|calls| 587028d9_69c4_7ed8_45fe_d86e3f085696
  ff1cc135_559f_c237_6539_8d8ba268c8e8["_merge_configs()"]
  587028d9_69c4_7ed8_45fe_d86e3f085696 -->|calls| ff1cc135_559f_c237_6539_8d8ba268c8e8
  67cad9a2_ee89_d44e_40ab_e55a36396c0d["astream_events()"]
  587028d9_69c4_7ed8_45fe_d86e3f085696 -->|calls| 67cad9a2_ee89_d44e_40ab_e55a36396c0d
  style 587028d9_69c4_7ed8_45fe_d86e3f085696 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 5893–5902

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