Struct SubscriptionSender 

pub struct SubscriptionSender { /* private fields */ }

Sender half that tags messages with a subscription id before sending.

Implementations

impl SubscriptionSender

pub fn new(sid: SubscriptionId, tx: Sender<TaggedMessage>) -> Self

pub fn sid(&self) -> SubscriptionId

pub fn try_send(&self, msg: Message) -> bool

Try to send a message without blocking. Returns false if the channel is full.

pub async fn send(&self, msg: Message) -> bool

pub fn is_closed(&self) -> bool

Check if the receiving end has been dropped.

Trait Implementations

impl Clone for SubscriptionSender

fn clone(&self) -> SubscriptionSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionSender

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

Formats the value using the given formatter.