stream() — langchain Function Reference

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

Function python LangChainCore Runnables calls 3

Entity Profile

LangChainCore→ Runnables→ stream() — langchain Function Reference

Dependency Diagram

graph TD
  d947aa85_3ece_1be3_71e0_d9e8f04de78b["stream()"]
  8b44d2a6_6c89_4ea1_b8c7_64e60123bbbe["RunnablePick"]
  d947aa85_3ece_1be3_71e0_d9e8f04de78b -->|defined in| 8b44d2a6_6c89_4ea1_b8c7_64e60123bbbe
  fe63d77f_0665_55ba_e4bf_6bb86b5251c0["transform()"]
  d947aa85_3ece_1be3_71e0_d9e8f04de78b -->|calls| fe63d77f_0665_55ba_e4bf_6bb86b5251c0
  9fc793b3_b726_058a_aebb_ca81faf79b43["stream()"]
  d947aa85_3ece_1be3_71e0_d9e8f04de78b -->|calls| 9fc793b3_b726_058a_aebb_ca81faf79b43
  6b634a0f_8373_1838_7f85_ec4585108419["transform()"]
  d947aa85_3ece_1be3_71e0_d9e8f04de78b -->|calls| 6b634a0f_8373_1838_7f85_ec4585108419
  style d947aa85_3ece_1be3_71e0_d9e8f04de78b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/passthrough.py lines 822–828

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