pub fn broadcast_message(&self, msg: SerialResponse) -> Vec<Error> {
    debug!("Broadcasting '{}' to all subscribers", &msg);
    let mut res = Vec::new();
    for (sub_id, sub) in self.subscriptions.iter() {
      match self.send_message(sub_id, msg.clone()) {
        Err(e) => res.push(e),
        _ => debug!("  Broadcast to '{}' was successful", sub_id),
      }
    }
    res
  }
/// Broadcast a messages to all subscribers, returning
/// a vec of (sub_id,ErrorKind::SendResponse) failures if some sends fail
Broadcast a messages to all subscribers, returning
a vec of (sub_id,ErrorKind::SendResponse) failures if some sends fail
Broadcast a messages to all subscribers returning a vec of ( sub_id ErrorKind :: SendResponse ) failures if some sends fail
pub fn broadcast_message(&self, msg: SerialResponse) -> Vec<Error> {
    debug!("Broadcasting '{}' to all subscribers", &msg);
    let mut res = Vec::new();
    for (sub_id, sub) in self.subscriptions.iter() {
      match self.send_message(sub_id, msg.clone()) {
        Err(e) => res.push(e),
        _ => debug!("  Broadcast to '{}' was successful", sub_id),
      }
    }
    res
  }
pub fn broadcast_message ( & self , msg : SerialResponse ) -> Vec < Error > { debug ! ( " " msg ) ; let mut res = Vec :: new ( ) ; for ( sub_id , sub ) in self . subscriptions . iter ( ) { match self . send_message ( sub_id , msg . clone ( ) ) { Err ( e ) => res . push ( e ) , _ => debug ! ( " " sub_id ) , } } res }
Broadcast a messages to all subscribers, returning
a vec of (sub_id,ErrorKind::SendResponse) failures if some sends fail
Broadcast a messages to all subscribers returning a vec of ( sub_id ErrorKind :: SendResponse ) failures if some sends fail
&self
msg
SerialResponse
&self
msg
SerialResponse