pub fn ctor_notify(&self, info: StateInfo) -> bool {
        if !self.active() {
            return false
        }
        let dups = self.states
            .iter()
            .filter(|&(_, ref state)| (state.fd.equals(&info.fd) && (state.id.clone() & info.id.clone())))
            .count();
        if dups > self.cfg.max_racers_count {
            return false
        }
        self.observers_state
            .iter()
            .all(|obs| obs.notify_ctor(&info))
    }
/// state creation callback
///
/// - checking dups ( same state already in queue - limit from config -> how many to allow )
state creation callback
checking dups ( same state already in queue - limit from config -> how many to allow )
state creation callback checking dups ( same state already in queue - limit from config - > how many to allow )
pub fn ctor_notify(&self, info: StateInfo) -> bool {
        if !self.active() {
            return false
        }
        let dups = self.states
            .iter()
            .filter(|&(_, ref state)| (state.fd.equals(&info.fd) && (state.id.clone() & info.id.clone())))
            .count();
        if dups > self.cfg.max_racers_count {
            return false
        }
        self.observers_state
            .iter()
            .all(|obs| obs.notify_ctor(&info))
    }
pub fn ctor_notify ( & self , info : StateInfo ) -> bool { if ! self . active ( ) { return false } let dups = self . states . iter ( ) . filter ( | & ( _ , ref state ) | ( state . fd . equals ( & info . fd ) && ( state . id . clone ( ) & info . id . clone ( ) ) ) ) . count ( ) ; if dups > self . cfg . max_racers_count { return false } self . observers_state . iter ( ) . all ( | obs | obs . notify_ctor ( & info ) ) }
state creation callback
 checking dups ( same state already in queue - limit from config -> how many to allow )
state creation callback checking dups ( same state already in queue - limit from config - > how many to allow )
&self
info
StateInfo
&self
info
StateInfo