/// Initiate an endless future that performs periodic health
/// checks for the service
Initiate an endless future that performs periodic health
checks for the service
Initiate an endless future that performs periodic health checks for the service
fn start_health_checks(&mut self, executor: &TaskExecutor) {
        let (handle, f) = sup_futures::cancelable_future(self.health_state().check_repeatedly());
        self.health_check_handle = Some(handle);
        let service_group_copy = self.service_group.clone();
        executor.spawn(f.map_err(move |err| {
                                                   if err.is_some() {
                                                       warn!("Health checking for {} \
                                                              unexpectedly errored!",
                                                             service_group_copy);
                                                   } else {
                                                       outputln!(preamble service_group_copy,
                                                                 "Health checking has been stopped");
                                                   }
                                               }));
    }
fn start_health_checks ( & mut self , executor : & TaskExecutor ) { let ( handle , f ) = sup_futures :: cancelable_future ( self . health_state ( ) . check_repeatedly ( ) ) ; self . health_check_handle = Some ( handle ) ; let service_group_copy = self . service_group . clone ( ) ; executor . spawn ( f . map_err ( move | err | { if err . is_some ( ) { warn ! ( " \
 " service_group_copy ) ; } else { outputln ! ( preamble service_group_copy " " ) ; } } ) ) ; }
Initiate an endless future that performs periodic health
checks for the service
Initiate an endless future that performs periodic health checks for the service
&mut self
executor
&TaskExecutor