Struct 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 duplicate 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>