astream() — langchain Function Reference

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

Function python LangChainCore Runnables

Entity Profile

LangChainCore→ Runnables→ astream() — langchain Function Reference

Dependency Diagram

graph TD
  13f3d275_21f2_3aa0_4fc8_30a58c2bc56a["astream()"]
  bf7edb6a_efe2_778a_5204_a2813723040a["TestRunnableSequenceParallelTraceNesting"]
  13f3d275_21f2_3aa0_4fc8_30a58c2bc56a -->|defined in| bf7edb6a_efe2_778a_5204_a2813723040a
  style 13f3d275_21f2_3aa0_4fc8_30a58c2bc56a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/tests/unit_tests/runnables/test_tracing_interops.py lines 403–406

    async def astream(
        parent: RunnableLambda[int, int], cb: list[BaseCallbackHandler]
    ) -> int:
        return [res async for res in parent.astream(1, {"callbacks": cb})][-1]