pub fn run(&mut self) -> ExitStatus {
        unsafe {
            prctl(PR_SET_CHILD_SUBREAPER, 1, 0, 0, 0);
        }
        supervisor::init();

        let dispatcher = Bus::new(true);
        debug!("Services: {:?}", self.services);
        // Spawn helper threads:
        healthcheck::spawn(dispatcher.join_bus(), self.services.clone());
        let handle = supervisor::spawn(dispatcher.join_bus(), self.services.clone());
        dispatcher.run();
        handle.join().unwrap()
    }
/// Blocking call, will setup the event loop and the threads and run all the available services.
Blocking call, will setup the event loop and the threads and run all the available services.
Blocking call will setup the event loop and the threads and run all the available services .
pub fn run(&mut self) -> ExitStatus {
        unsafe {
            prctl(PR_SET_CHILD_SUBREAPER, 1, 0, 0, 0);
        }
        supervisor::init();
        let dispatcher = Bus::new(true);
        debug!("Services: {:?}", self.services);
        // Spawn helper threads:
        healthcheck::spawn(dispatcher.join_bus(), self.services.clone());
        let handle = supervisor::spawn(dispatcher.join_bus(), self.services.clone());
        dispatcher.run();
        handle.join().unwrap()
    }
pub fn run ( & mut self ) -> ExitStatus { unsafe { prctl ( PR_SET_CHILD_SUBREAPER , 1 , 0 , 0 , 0 ) ; } supervisor :: init ( ) ; let dispatcher = Bus :: new ( true ) ; debug ! ( " " self services ) ; // Spawn helper threads: healthcheck :: spawn ( dispatcher . join_bus ( ) , self . services . clone ( ) ) ; let handle = supervisor :: spawn ( dispatcher . join_bus ( ) , self . services . clone ( ) ) ; dispatcher . run ( ) ; handle . join ( ) . unwrap ( ) }
Blocking call, will setup the event loop and the threads and run all the available services.
Blocking call will setup the event loop and the threads and run all the available services .
&mut self
&mut self