Struct CompletionNotifier 

pub struct CompletionNotifier { /* private fields */ }

Multi-consumer completion notification channel for a workflow execution.

Implementations

impl CompletionNotifier

pub fn new() -> Self

Creates an unfulfilled completion notifier.

pub fn subscribe(&self) -> Receiver<Option<TerminalOutcome>>

Subscribes a result awaiter to the eventual terminal outcome.

pub fn notify(&self, outcome: TerminalOutcome)

Publishes the terminal outcome to all current and future subscribers.

The value is stored even when no result waiter is currently subscribed, so a waiter that subscribed from a still-held handle before deregistration can observe the terminal outcome instead of hanging on an unfulfilled channel.

pub fn is_completed(&self) -> bool

Returns true once a terminal outcome has been published.

Trait Implementations

impl Clone for CompletionNotifier

fn clone(&self) -> CompletionNotifier

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompletionNotifier

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

Formats the value using the given formatter.

impl Default for CompletionNotifier

fn default() -> Self

Returns the “default value” for a type.

impl Eq for CompletionNotifier

impl PartialEq for CompletionNotifier

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.