stream() — langchain Function Reference

Architecture documentation for the stream() function in base.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
  c67e8e45_1bd5_b0a5_81a0_565db37b3f07["stream()"]
  17599172_8889_afc6_2237_4429f3439071["RunnableParallel"]
  c67e8e45_1bd5_b0a5_81a0_565db37b3f07 -->|defined in| 17599172_8889_afc6_2237_4429f3439071
  38807d67_690b_db51_4b6a_d357e2a415b0["stream()"]
  38807d67_690b_db51_4b6a_d357e2a415b0 -->|calls| c67e8e45_1bd5_b0a5_81a0_565db37b3f07
  b19bb5c5_7d06_0da1_c670_6107a6c35950["transform()"]
  c67e8e45_1bd5_b0a5_81a0_565db37b3f07 -->|calls| b19bb5c5_7d06_0da1_c670_6107a6c35950
  98b849a3_219d_3646_6770_861e1bddb28f["stream()"]
  c67e8e45_1bd5_b0a5_81a0_565db37b3f07 -->|calls| 98b849a3_219d_3646_6770_861e1bddb28f
  style c67e8e45_1bd5_b0a5_81a0_565db37b3f07 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 4007–4013

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