Struct ProducerLifecycle 

pub struct ProducerLifecycle { /* private fields */ }

Manages background-task lifecycle for a set of SourceHandles.

The lifecycle:

1. Construct with ProducerLifecycle::new (or with_parent_signal to inherit a shared cancellation tree).
2. For each registered source, call spawn_from_source — the source’s own loop observes the lifecycle’s Signal cooperatively and returns once it has drained.
3. Hand callers a clone of cancel_signal if they need to coordinate their own shutdown observation.
4. On shutdown, call shutdown with a grace Duration. The signal is fired; tasks that finish within the grace count as drained; tasks that don’t are aborted and count as aborted.

Implementations

impl ProducerLifecycle

pub fn new() -> Self

Construct a new lifecycle with a fresh root cancellation token.

pub fn with_parent_signal(parent: &Signal) -> Self

Construct from a parent token; cancelling the parent cancels this lifecycle’s child token too. Useful when a higher-level shutdown (e.g. the app-level oneshot signal) owns the root token.

pub fn cancel_signal(&self) -> Signal

Return a clone of the cancellation token. Callers that need to observe shutdown alongside the spawned tasks (e.g. the listener serve loop) can race against this.

pub fn spawn_from_source(&mut self, name: &str, source: &SourceHandle)

Spawn source under this lifecycle’s shared cancellation Signal.

Unlike a wrapper-cancelled task, the source’s own loop receives the lifecycle’s real Signal as its call input and observes it cooperatively (see run_interval_loop’s select_biased! against cancel.fired()) — cancellation is not drop-based, the source returns on its own once it has drained.

pub fn task_count(&self) -> usize

Number of tasks currently being managed.

pub fn spawned_task_names(&self) -> impl Iterator<Item = &str>

Names of all spawned tasks (in spawn order), per spawn_from_source.

pub async fn shutdown(self, grace: Duration) -> ShutdownReport

Initiate graceful shutdown.

1. Cancel the lifecycle’s token so cooperating tasks observe cancellation.
2. Drain the join set with the given grace deadline. Tasks that exit within the grace count as drained; tasks that don’t are aborted and count as aborted. Tasks that panicked are noted in ShutdownReport::panics and count as aborted (the task did not drain cleanly).

Consumes self, so the lifecycle cannot be re-used after shutdown.

Trait Implementations

impl Debug for ProducerLifecycle

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ProducerLifecycle

fn default() -> Self

Returns the “default value” for a type.