pub fn add(&mut self, id: impl ToString, query: impl ToString, tx: SubscriptionTx) {
        let query = query.to_string();
        let subs_for_query = match self.subscriptions.get_mut(&query) {
            Some(s) => s,
            None => {
                self.subscriptions.insert(query.clone(), HashMap::new());
                self.subscriptions.get_mut(&query).unwrap()
            }
        };

        subs_for_query.insert(id.to_string(), tx);
    }
/// Immediately add a new subscription to the router without waiting for
/// confirmation.
Immediately add a new subscription to the router without waiting for
confirmation.
Immediately add a new subscription to the router without waiting for confirmation .
pub fn add(&mut self, id: impl ToString, query: impl ToString, tx: SubscriptionTx) {
        let query = query.to_string();
        let subs_for_query = match self.subscriptions.get_mut(&query) {
            Some(s) => s,
            None => {
                self.subscriptions.insert(query.clone(), HashMap::new());
                self.subscriptions.get_mut(&query).unwrap()
            }
        };
        subs_for_query.insert(id.to_string(), tx);
    }
pub fn add ( & mut self , id : impl ToString , query : impl ToString , tx : SubscriptionTx ) { let query = query . to_string ( ) ; let subs_for_query = match self . subscriptions . get_mut ( & query ) { Some ( s ) => s , None => { self . subscriptions . insert ( query . clone ( ) , HashMap :: new ( ) ) ; self . subscriptions . get_mut ( & query ) . unwrap ( ) } } ; subs_for_query . insert ( id . to_string ( ) , tx ) ; }
Immediately add a new subscription to the router without waiting for
confirmation.
Immediately add a new subscription to the router without waiting for confirmation .
&mut self
id
impl ToString
query
impl ToString
tx
SubscriptionTx