Struct postage::watch::Sender

pub struct Sender<T> { /* fields omitted */ }

The sender half of a watch channel. The stored value can be updated with the postage::Sink trait.

Trait Implementations

impl<T> Sink for Sender<T>

type Item = T

pub fn poll_send(
    self: Pin<&mut Self>,
    _cx: &mut Context<'_>,
    value: Self::Item
) -> PollSend<Self::Item>

Attempts to accept the message, without blocking.
Returns PollSend::Ready, PollSend::Pending(value), or PollSend::Rejected(value)

pub fn send(&mut self, value: Self::Item) -> SendFuture<'_, Self>

Attempts to send a message into the sink.

pub fn try_send(
    &mut self,
    value: Self::Item
) -> Result<(), TrySendError<Self::Item>> where
    Self: Unpin, 

Attempts to send a message over the sink, without blocking.

pub fn after<Before>(self, before: Before) -> SinkChain<Before, Self> where
    Before: Sink<Item = Self::Item>,
    Self: Sized, 

Chains two sink implementations. Messages will be transmitted to the argument until it rejects a message. Then messages will be transmitted to self.

pub fn filter<Filter>(self, filter: Filter) -> SinkFilter<Filter, Self> where
    Filter: FnMut(&Self::Item) -> bool,
    Self: Sized, 

Filters messages, forwarding them to the sink if the filter returns true

pub fn log(self, level: Level) -> SinkLog<Self> where
    Self: Sized,
    Self::Item: Debug, 

Logs messages that are accepted by the sink using the Debug trait, at the provided log level.