stream() — langchain Function Reference

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

Function python LangChainCore Runnables

Entity Profile

LangChainCore→ Runnables→ stream() — langchain Function Reference

Dependency Diagram

graph TD
  239f8300_2035_8508_61eb_b82e9c1ebac4["stream()"]
  65b9aaca_53f2_847d_9ab7_024fe53cbbd2["RouterRunnable"]
  239f8300_2035_8508_61eb_b82e9c1ebac4 -->|defined in| 65b9aaca_53f2_847d_9ab7_024fe53cbbd2
  style 239f8300_2035_8508_61eb_b82e9c1ebac4 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/router.py lines 209–222

    def stream(
        self,
        input: RouterInput,
        config: RunnableConfig | None = None,
        **kwargs: Any | None,
    ) -> Iterator[Output]:
        key = input["key"]
        actual_input = input["input"]
        if key not in self.runnables:
            msg = f"No runnable associated with key '{key}'"
            raise ValueError(msg)

        runnable = self.runnables[key]
        yield from runnable.stream(actual_input, config)