Function spawn_loop

nodedb/src/control/shutdown/spawn.rs:52–70

Spawn an async loop on the tokio runtime. The `body` closure receives a [`ShutdownReceiver`] it MUST select on to observe shutdown. Example: ```ignore use crate::control::shutdown::spawn_loop; spawn_loop( &shared.loop_registry, &shared.shutdown, "wal_catchup", |mut shutdown| async move { let mut tick = tokio::time::interval(Duration::from_millis(50)); loop { tokio::select! { _ = shutdown.wait_c

(
    registry: &LoopRegistry,
    shutdown: &ShutdownWatch,
    name: &'static str,
    body: F,
)

/// the caller can meaningfully handle, because a registration
/// race means shutdown has already fired.
pub fn spawn_loop<F, Fut>(
    registry: &LoopRegistry,
    shutdown: &ShutdownWatch,
    name: &'static str,
    body: F,
) where
    F: FnOnce(ShutdownReceiver) -> Fut + Send + 'static,
    Fut: Future<Output = ()> + Send + 'static,
{
    let rx = shutdown.subscribe();
    let handle = tokio::spawn(async move { body(rx).await });
    if let Err(e) = registry.register(name, LoopHandle::Async(handle)) {
        tracing::warn!(
            error = %e,
            "spawn_loop after registry close — task will run to completion \
             but shutdown_all will not wait for it"
        );
    }
}

/// Spawn a blocking loop via `tokio::task::spawn_blocking`.
/// Same semantics as [`spawn_loop`] except the body runs on a