Struct BroadcastDropStrategy 

pub struct BroadcastDropStrategy<M: Mode> { /* private fields */ }

A drop strategy which broadcasts a drop error to all receivers.

Implementations

impl<M: Mode> BroadcastDropStrategy<M>

pub fn new(capacity: usize) -> (Self, BlockingReceiver<ArcError>)

Create a new broadcast drop strategy from a handle to the current tokio runtime.

pub fn new_with( capacity: usize, handle: Handle, ) -> (Self, BlockingReceiver<ArcError>)

Create a new broadcast drop strategy, with a handle to a tokio runtime.

pub fn subscribe(&self) -> BlockingReceiver<ArcError>

Subscribe to this drop strategy, receiving new errors.

Trait Implementations

impl<M: Clone + Mode> Clone for BroadcastDropStrategy<M>

fn clone(&self) -> BroadcastDropStrategy<M>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M: Debug + Mode> Debug for BroadcastDropStrategy<M>

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

Formats the value using the given formatter.

impl FallibleTryDropStrategy for BroadcastDropStrategy<NeedsReceivers>

type Error = SendError<ArcError>

The type of the error that may occur when handling a drop error.

fn try_handle_error(&self, error: Error) -> Result<(), Self::Error>

Try and handle a drop error.

impl TryDropStrategy for BroadcastDropStrategy<OkIfAlone>

fn handle_error(&self, error: Error)

Handle the drop error.