Struct postage::broadcast::Sender

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

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.

Note: no implementation of the futures::Sink trait is provided for the broadcast Sender.

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>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Sender<T>

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

Formats the value using the given formatter.

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

type Item = T

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

Attempts to accept the message, without blocking.

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

Attempts to send a message into the sink.

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.

fn after<Before>(self, before: Before) -> ChainSink<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.

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

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

impl<T: Send> Send for Sender<T>

impl<T: Send> Sync for Sender<T>