pub fn send_message(&self, sub_id: &String, msg: SerialResponse) -> Result<()> {
    match self.subscriptions.get(sub_id) {
      None => Err(ErrorKind::SubscriptionNotFound(sub_id.to_string()).into()),
      Some(sub) => sub
        .subscriber
        .send(msg)
        .map_err(|e| ErrorKind::SendResponse(e).into()),
    }
  }
/// Send a message to the given subscription
Send a message to the given subscription
Send a message to the given subscription
pub fn send_message(&self, sub_id: &String, msg: SerialResponse) -> Result<()> {
    match self.subscriptions.get(sub_id) {
      None => Err(ErrorKind::SubscriptionNotFound(sub_id.to_string()).into()),
      Some(sub) => sub
        .subscriber
        .send(msg)
        .map_err(|e| ErrorKind::SendResponse(e).into()),
    }
  }
pub fn send_message ( & self , sub_id : & String , msg : SerialResponse ) -> Result < ( ) > { match self . subscriptions . get ( sub_id ) { None => Err ( ErrorKind :: SubscriptionNotFound ( sub_id . to_string ( ) ) . into ( ) ) , Some ( sub ) => sub . subscriber . send ( msg ) . map_err ( | e | ErrorKind :: SendResponse ( e ) . into ( ) ) , } }
Send a message to the given subscription
Send a message to the given subscription
&self
sub_id
&String
msg
SerialResponse
&self
sub_id
&String
msg
SerialResponse