···

       
40
       
 
       


     

       
41
       
 
       
        // TODO: do we need to timeout ws sends??

     

       
42
       
 
       


     

       
0
       
 
       

     

       
0
       
 
       

     

       
43
       
 
       
        loop {

     

       
44
       
 
       
            tokio::select! {

     

       
45
       
 
       
                l = receiver.recv() => match l {

     
···

       
109
       
 
       
            }

     

       
110
       
 
       
        }

     

       
111
       
 
       
        log::trace!("end of subscriber. bye!");

     

       
0
       
 
       

     

       
112
       
 
       
        Ok(())

     

       
113
       
 
       
    }

     

       
114
       
 
       


     

···

       
40
       
 
       


     

       
41
       
 
       
        // TODO: do we need to timeout ws sends??

     

       
42
       
 
       


     

       
43
       
+
       
        metrics::gauge!("subscribers_connected_total").increment(1);

     

       
44
       
+
       


     

       
45
       
 
       
        loop {

     

       
46
       
 
       
            tokio::select! {

     

       
47
       
 
       
                l = receiver.recv() => match l {

     
···

       
111
       
 
       
            }

     

       
112
       
 
       
        }

     

       
113
       
 
       
        log::trace!("end of subscriber. bye!");

     

       
114
       
+
       
        metrics::gauge!("subscribers_connected_total").decrement(1);

     

       
115
       
 
       
        Ok(())

     

       
116
       
 
       
    }

     

       
117