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
    Checkpoint Postgres
    Store Postgres
    Checkpoint SQLite
    LangGraph Prebuilt
    LangGraph CLI
    LangGraph SDK
    LangGraph Supervisor
    LangGraph Swarm
    ⌘I

    LangChain Assistant

    Ask a question to get started

    Enter to send•Shift+Enter new line

    Menu

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

    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)