Struct Shutdown 

pub struct Shutdown { /* private fields */ }

A cloneable handle used to request and observe server shutdown.

Every clone refers to the same underlying signal. The server stops accepting connections once it is triggered, background tasks receive it, and long-lived handlers (WebSockets, streaming responses) should watch it to finish cleanly:

use kerniq_runtime::Shutdown;

let shutdown = Shutdown::new();
let watcher = shutdown.clone();
let task = tokio::spawn(async move {
    watcher.wait().await;
    "stopped"
});
shutdown.trigger();
assert_eq!(task.await.unwrap(), "stopped");

Implementations

impl Shutdown

pub fn new() -> Self

Creates a new, untriggered handle.

pub fn trigger(&self)

Requests shutdown. Idempotent.

pub fn is_triggered(&self) -> bool

Whether shutdown has been requested.

pub async fn wait(&self)

Completes once shutdown has been requested. Cancel-safe.

pub fn wait_owned(&self) -> impl Future<Output = ()> + Send + 'static

An owned future that completes on shutdown (useful for select! in 'static contexts).

pub fn token(&self) -> &CancellationToken

The underlying Tokio cancellation token, for interoperability.

Trait Implementations

impl Clone for Shutdown

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Shutdown

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

Formats the value using the given formatter.

impl Default for Shutdown

fn default() -> Self

Returns the “default value” for a type.

impl From<CancellationToken> for Shutdown

fn from(token: CancellationToken) -> Self

Converts to this type from the input type.