stream() — langchain Function Reference

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

Function python LangChainCore Runnables calls 2 called by 1

Entity Profile

LangChainCore→ Runnables→ stream() — langchain Function Reference

Dependency Diagram

graph TD
  3e9c06ec_de75_0159_daf0_82c2499729cd["stream()"]
  915f0e72_2130_6a8d_6929_3a7528446033["RunnablePassthrough"]
  3e9c06ec_de75_0159_daf0_82c2499729cd -->|defined in| 915f0e72_2130_6a8d_6929_3a7528446033
  9fc793b3_b726_058a_aebb_ca81faf79b43["stream()"]
  9fc793b3_b726_058a_aebb_ca81faf79b43 -->|calls| 3e9c06ec_de75_0159_daf0_82c2499729cd
  8d2a37b9_a0ae_643b_9bbd_130393223126["transform()"]
  3e9c06ec_de75_0159_daf0_82c2499729cd -->|calls| 8d2a37b9_a0ae_643b_9bbd_130393223126
  9fc793b3_b726_058a_aebb_ca81faf79b43["stream()"]
  3e9c06ec_de75_0159_daf0_82c2499729cd -->|calls| 9fc793b3_b726_058a_aebb_ca81faf79b43
  style 3e9c06ec_de75_0159_daf0_82c2499729cd fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/passthrough.py lines 327–333

    def stream(
        self,
        input: Other,
        config: RunnableConfig | None = None,
        **kwargs: Any,
    ) -> Iterator[Other]:
        return self.transform(iter([input]), config, **kwargs)