pub fn send<D: DurationTicks>(&self, item: T, max_wait: D) -> usize {
        let mut sent_to = 0;

        if let Ok(m) = self.inner.lock(max_wait) {
            for subscriber in &m.subscribers {
                if let Ok(_) = subscriber.queue.send(item, max_wait) {
                    sent_to += 1;
                }
            }
        }

        sent_to
    }
/// Send an item to every subscriber. Returns the number of
/// subscribers that have received the item.
Send an item to every subscriber. Returns the number of
subscribers that have received the item.
Send an item to every subscriber . Returns the number of subscribers that have received the item .
pub fn send<D: DurationTicks>(&self, item: T, max_wait: D) -> usize {
        let mut sent_to = 0;
        if let Ok(m) = self.inner.lock(max_wait) {
            for subscriber in &m.subscribers {
                if let Ok(_) = subscriber.queue.send(item, max_wait) {
                    sent_to += 1;
                }
            }
        }
        sent_to
    }
pub fn send < D : DurationTicks > ( & self , item : T , max_wait : D ) -> usize { let mut sent_to = 0 ; if let Ok ( m ) = self . inner . lock ( max_wait ) { for subscriber in & m . subscribers { if let Ok ( _ ) = subscriber . queue . send ( item , max_wait ) { sent_to += 1 ; } } } sent_to }
Send an item to every subscriber.
Send an item to every subscriber .
&self
item
T
max_wait
D
&self
item
T
max_wait
D