Struct SpawnEssentialTaskHandle

pub struct SpawnEssentialTaskHandle { /* private fields */ }

A wrapper over SpawnTaskHandle that will notify a receiver whenever any task spawned through it fails. The service should be on the receiver side and will shut itself down whenever it receives any message, i.e. an essential task has failed.

Implementations

impl SpawnEssentialTaskHandle

pub fn new( essential_failed_tx: TracingUnboundedSender<()>, spawn_task_handle: SpawnTaskHandle, ) -> SpawnEssentialTaskHandle

Creates a new SpawnEssentialTaskHandle.

pub fn spawn( &self, name: &'static str, group: impl Into<GroupName>, task: impl Future<Output = ()> + Send + 'static, )

Spawns the given task with the given name.

See also SpawnTaskHandle::spawn.

pub fn spawn_blocking( &self, name: &'static str, group: impl Into<GroupName>, task: impl Future<Output = ()> + Send + 'static, )

Spawns the blocking task with the given name.

See also SpawnTaskHandle::spawn_blocking.

Trait Implementations

impl Clone for SpawnEssentialTaskHandle

fn clone(&self) -> SpawnEssentialTaskHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SpawnEssentialNamed for SpawnEssentialTaskHandle

fn spawn_essential_blocking( &self, name: &'static str, group: Option<&'static str>, future: BoxFuture<'static, ()>, )

Spawn the given blocking future.

fn spawn_essential( &self, name: &'static str, group: Option<&'static str>, future: BoxFuture<'static, ()>, )

Spawn the given non-blocking future.