Skip to main content

Module loop_

Module loop_ 

Source
Expand description

Activity polling loop and shutdown primitives. receive->dispatch->report worker loop + bounded concurrency

Structs§

SessionHealth
Per-session health accounting written by the serve loop for the reconnect-aware caller’s drop-budget reset decision.

Enums§

DispatchOutcome
Activity execution outcome returned by the dispatch seam.
ServeEnd
Why the serve loop ended without an error.

Traits§

ActivityDispatcher
Dispatch seam used by the receive loop to execute decoded activity tasks.

Functions§

serve_activity_tasks
Runs the worker receive loop until the session’s task stream completes.
serve_activity_tasks_until
Runs the worker receive loop until the session’s task stream completes.

Type Aliases§

NoShutdown
Future that never resolves, used by the default serve entrypoint.