Struct tor_basic_utils::futures::DropNotifyWatchSender

pub struct DropNotifyWatchSender<T: Default>(_);

Wrapper for postage::watch::Sender that sends Default when dropped

Derefs to the inner Sender.

Ideally this would be behaviour promised by upstream, or something See https://github.com/austinjones/postage-rs/issues/57.

Implementations

impl<T: Default> DropNotifyWatchSender<T>

pub fn new(inner: Sender<T>) -> Self

Arrange to send T::Default when inner is dropped

pub fn into_inner(self) -> Sender<T>

Unwrap the inner sender, defusing the drop notification

Methods from Deref<Target = Sender<T>>

pub fn borrow_mut(&'s mut self) -> RefMut<'s, T>

Mutably borrows the contained value, blocking the channel while the borrow is held.

After the borrow is released, receivers will be notified of a new value.

pub fn subscribe(&mut self) -> Receiver<T>

Creates a new Receiver that listens to this channel.

pub fn borrow(&'s mut self) -> Ref<'s, T>

Immutably borrows the contained value, blocking the channel while the borrow is held.

Trait Implementations

impl<T: Debug + Default> Debug for DropNotifyWatchSender<T>

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

Formats the value using the given formatter.

impl<T: Default> Deref for DropNotifyWatchSender<T>

type Target = Sender<T>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T: Default> DerefMut for DropNotifyWatchSender<T>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T: Default> Drop for DropNotifyWatchSender<T>

fn drop(&mut self)

Executes the destructor for this type.