Struct ShutdownCoordinator 

pub struct ShutdownCoordinator { /* private fields */ }

Coordinates the shutdown of multiple components.

Implementations

impl ShutdownCoordinator

pub fn new() -> Self

Create a new shutdown coordinator.

pub fn register(&self) -> ShutdownSignal

Register a new component to be managed by this coordinator. Returns a ShutdownSignal that the component should hold and listen to.

pub fn broadcast(&self, reason: ShutdownReason)

Broadcast a shutdown signal to all registered components.

pub async fn wait(self)

Wait for all registered components to finish shutting down.

This consumes the coordinator, dropping the ack_tx sender so that the ack_rx receiver will return None once all ShutdownSignals are dropped.

Trait Implementations

impl Debug for ShutdownCoordinator

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

Formats the value using the given formatter.

impl Default for ShutdownCoordinator

fn default() -> Self

Returns the “default value” for a type.