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_muxStreamMuxapush
    Method●Since v1.1

    apush

    Copy
    apush(
        self,
        event: ProtocolEvent,
    ) -> None
    View source on GitHub

    Parameters

    NameTypeDescription
    event*ProtocolEvent

    The protocol event to dispatch.

    Dispatch an event on the async lane.

    Awaits each transformer's aprocess in registration order before appending to the main log. A slow aprocess serializes the pipeline by design — that's the guarantee that lets a later transformer (or a synchronous consumer) see the result of the async work. For decoupled work, use schedule() from inside process / aprocess instead.

    The main log append is a non-blocking push — matching v1's put_nowait shape. The root mux assigns seq; child muxes do not, so forwarded subgraph events can be shared without copying. Memory is bounded by caller pace via the caller-driven pump; see StreamChannel for the full tradeoff story.