Struct postage::broadcast::Sender

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

A broadcast sender that can be used with the postage::Sink trait. Can be cloned.

The sender task is suspended when the internal buffer is filled.

Implementations

impl<T> Sender<T>

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

Subscribes to the channel, creating a new receiver. The receiver will observe all messages sent after the call to subscribe.

Messages currently in the buffer are not received.

Trait Implementations

impl<T> Clone for Sender<T>

pub fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Sink for Sender<T> where
    T: Clone, 

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.