LangChain Reference home pageLangChain ReferenceLangChain Reference
  • GitHub
  • Main Docs
Deep Agents
LangChain
LangGraph
Integrations
LangSmith
  • Overview
    • Overview
    • Graphs
    • Functional API
    • Pregel
    • Checkpointing
    • Storage
    • Caching
    • Types
    • Runtime
    • Config
    • Errors
    • Constants
    • Channels
    • Agents
    LangGraph Checkpoint
    LangGraph Store
    Checkpoint Postgres
    Store Postgres
    Checkpoint SQLite
    LangGraph Prebuilt
    LangGraph CLI
    LangGraph SDK
    LangGraph Supervisor
    LangGraph Swarm
    โŒ˜I

    Chat LangChain

    What can I help with?

    Enter to sendยทShift+Enter new line

    Menu

    OverviewGraphsFunctional APIPregelCheckpointingStorageCachingTypesRuntimeConfigErrorsConstantsChannelsAgents
    LangGraph Checkpoint
    LangGraph Store
    Checkpoint Postgres
    Store Postgres
    Checkpoint SQLite
    LangGraph Prebuilt
    LangGraph CLI
    LangGraph SDK
    LangGraph Supervisor
    LangGraph Swarm
    Language
    Theme
    Pythonlanggraphstream_muxStreamMuxbind_pump
    Methodโ—Since v1.2

    bind_pump

    Copy
    bind_pump(
        self,
        fn: Callable[[], bool],
    ) -> None
    View source on GitHub

    Wire the sync pull callback onto every projection in this mux.

    Records the pump on the mux so child mini-muxes built by _make_child can inherit it. Propagates to:

    • the main event log (self._events)
    • every projection StreamChannel in extensions
    • any registered transformer that exposes _bind_pump (e.g. MessagesTransformer so ChatModelStream instances drive the shared pump from their cursors)