astream() — langchain Function Reference

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

Function python LangChainCore Runnables calls 3

Entity Profile

LangChainCore→ Runnables→ astream() — langchain Function Reference

Dependency Diagram

graph TD
  62530ed9_3d20_a587_0e13_a04ed805b3c4["astream()"]
  8b44d2a6_6c89_4ea1_b8c7_64e60123bbbe["RunnablePick"]
  62530ed9_3d20_a587_0e13_a04ed805b3c4 -->|defined in| 8b44d2a6_6c89_4ea1_b8c7_64e60123bbbe
  0f3c771a_cfa4_959e_f282_59837b63e8cf["atransform()"]
  62530ed9_3d20_a587_0e13_a04ed805b3c4 -->|calls| 0f3c771a_cfa4_959e_f282_59837b63e8cf
  29e5a61e_3192_fcb1_8408_ac325ae0e3cd["astream()"]
  62530ed9_3d20_a587_0e13_a04ed805b3c4 -->|calls| 29e5a61e_3192_fcb1_8408_ac325ae0e3cd
  68f322b4_1349_271a_408d_e2eb04ed643e["atransform()"]
  62530ed9_3d20_a587_0e13_a04ed805b3c4 -->|calls| 68f322b4_1349_271a_408d_e2eb04ed643e
  style 62530ed9_3d20_a587_0e13_a04ed805b3c4 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/passthrough.py lines 831–841

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

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