astream_events() — langchain Function Reference

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

Function python LangChainCore Runnables calls 1

Entity Profile

LangChainCore→ Runnables→ astream_events() — langchain Function Reference

Dependency Diagram

graph TD
  5a7343ac_4a18_f6fb_60ba_828186f81b91["astream_events()"]
  11e31530_bade_f413_97e7_9abc389b68c7["RunnableEachBase"]
  5a7343ac_4a18_f6fb_60ba_828186f81b91 -->|defined in| 11e31530_bade_f413_97e7_9abc389b68c7
  587028d9_69c4_7ed8_45fe_d86e3f085696["astream_events()"]
  5a7343ac_4a18_f6fb_60ba_828186f81b91 -->|calls| 587028d9_69c4_7ed8_45fe_d86e3f085696
  style 5a7343ac_4a18_f6fb_60ba_828186f81b91 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 5398–5410

    async def astream_events(
        self,
        input: Input,
        config: RunnableConfig | None = None,
        **kwargs: Any | None,
    ) -> AsyncIterator[StreamEvent]:
        def _error_stream_event(message: str) -> StreamEvent:
            raise NotImplementedError(message)

        for _ in range(1):
            yield _error_stream_event(
                "RunnableEach does not support astream_events yet."
            )