Struct pinky_swear::PinkyErrorBroadcaster

pub struct PinkyErrorBroadcaster<T, E: Clone> { /* private fields */ }

A PinkyErrorBroadcaster allows you to broacast the success/error of a promise resolution to several subscribers.

Implementations

impl<T: Send + 'static, E: Send + Clone + 'static> PinkyErrorBroadcaster<T, E>

pub fn new() -> (PinkySwear<Result<T, E>>, Self)

Create a new promise with associated error broadcaster

pub fn set_marker(&self, marker: String)

Add a marker to logs

pub fn subscribe(&self) -> PinkySwear<Result<(), E>>

Subscribe to receive a broacast when the underlying promise get henoured.

pub fn unsubscribe(&self, promise: PinkySwear<Result<(), E>>)

Unsubscribe a promise from the broadcast.

pub fn swear(&self, data: Result<T, E>)

Resolve the underlying promise and broadcast the result to subscribers.

Trait Implementations

impl<T, E: Clone> Debug for PinkyErrorBroadcaster<T, E>

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

Formats the value using the given formatter.