fn cleanup_bad_subs(&mut self, bad_subs: Vec<Error>) {
    for e in bad_subs {
      if let Error(ErrorKind::SubscriberSendError(sub_id), _) = e {
        // Remove subscriptions
        self.sub_manager.end_subscription(&sub_id);
        // Remove all write locks held by dead subscription
        self.writelock_manager.unlock_all_ports_for_sub(&sub_id);
      }
    }
  }
/// Cleanup any bad subs where a message send failed
Cleanup any bad subs where a message send failed
Cleanup any bad subs where a message send failed
fn cleanup_bad_subs(&mut self, bad_subs: Vec<Error>) {
    for e in bad_subs {
      if let Error(ErrorKind::SubscriberSendError(sub_id), _) = e {
        // Remove subscriptions
        self.sub_manager.end_subscription(&sub_id);
        // Remove all write locks held by dead subscription
        self.writelock_manager.unlock_all_ports_for_sub(&sub_id);
      }
    }
  }
fn cleanup_bad_subs ( & mut self , bad_subs : Vec < Error > ) { for e in bad_subs { if let Error ( ErrorKind :: SubscriberSendError ( sub_id ) , _ ) = e { // Remove subscriptions self . sub_manager . end_subscription ( & sub_id ) ; // Remove all write locks held by dead subscription self . writelock_manager . unlock_all_ports_for_sub ( & sub_id ) ; } } }
Cleanup any bad subs where a message send failed
Cleanup any bad subs where a message send failed
&mut self
bad_subs
Vec<Error>
&mut self
bad_subs
Vec<Error>