Struct ServiceLifecycle 

pub struct ServiceLifecycle<S> { /* private fields */ }

Runs one service future with shared Aster shutdown mechanics.

This lower-level helper exists for tests and uncommon one-off runners. New product entrypoints should prefer AsterRuntime::builder and register the main service through RuntimeServiceComponent.

Implementations

impl<S> ServiceLifecycle<S>

pub fn new(server: S, shutdown_token: CancellationToken) -> Self

Creates a lifecycle runner for server and shutdown_token.

impl<S> ServiceLifecycle<S>

where S: Future,

pub async fn run<Stop, StopFut, AfterStop, AfterStopFut>( self, stop_on_signal: Stop, after_stop: AfterStop, ) -> S::Output

where Stop: FnOnce() -> StopFut + Send + 'static, StopFut: Future<Output = ()> + Send + 'static, AfterStop: FnOnce() -> AfterStopFut, AfterStopFut: Future<Output = ()>,

Runs the service future and product cleanup hooks. Cancels and joins its signal listener before invoking after_stop; dropping this run future also aborts the listener so it cannot retain resources of an abandoned service. Cancellation is signalled before cleanup, including service panic and run cancellation.

Panics

Service panics are resumed with their original payload after after_stop. If only cleanup panics, its panic is resumed; if both panic, the original service panic takes precedence. Destruction of the completed service future is part of this boundary.