Struct Runner 

struct Runner<ServerT: Server> {
    pubhubs_server: Rc<ServerT>,
    shutdown_receiver: Receiver<Infallible>,
    worker_count: Option<NonZero<usize>>,
    generation: usize,
}

Runs a Server

Fields

pubhubs_server: Rc<ServerT>

shutdown_receiver: Receiver<Infallible>

worker_count: Option<NonZero<usize>>

generation: usize

Number of restarts (i.e. modifications applied)

Implementations

impl<S: Server> Runner<S>

pub fn new( global_config: &Config, shutdown_receiver: Receiver<Infallible>, worker_count: Option<NonZero<usize>>, ) -> Result<Self>

fn create_actix_server(&self) -> Result<Handles<S>>

pub async fn run(self) -> Result<()>

pub async fn run_until_modifier( &mut self, ) -> Result<Box<dyn Modifier<S>>, Error>

async fn run_until_modifier_inner( handles: &mut Handles<S>, runner: &mut Runner<S>, ) -> Result<Box<dyn Modifier<S>>, Error>