Method run

src/processor.rs:86–115

Start votes processor.

(self, cancel_token: &CancellationToken)

    /// Start votes processor.
    pub(crate) fn run(self, cancel_token: &CancellationToken) -> JoinAll<JoinHandle<()>> {
        let num_workers = COMMANDS_HANDLERS_WORKERS + VOTES_CLOSERS_WORKERS + 2; // Status checker + auto closer
        let mut workers_handles = Vec::with_capacity(num_workers);

        // Launch commands handler workers
        for _ in 0..COMMANDS_HANDLERS_WORKERS {
            let cmds_handler = CommandsHandler::new(self.db.clone(), self.gh.clone(), self.cmds_rx.clone());
            let cmds_handler_handle = cmds_handler.run(cancel_token.clone());
            workers_handles.push(cmds_handler_handle);
        }

        // Launch votes closer workers
        for _ in 0..VOTES_CLOSERS_WORKERS {
            let votes_closer = VotesCloser::new(self.db.clone(), self.gh.clone());
            let votes_closer_handler = votes_closer.run(cancel_token.clone());
            workers_handles.push(votes_closer_handler);
        }

        // Launch status checker
        let status_checker = StatusChecker::new(self.db.clone(), self.cmds_tx.clone());
        let status_checker_handle = status_checker.run(cancel_token.clone());
        workers_handles.push(status_checker_handle);

        // Launch votes auto closer
        let votes_auto_closer = VotesAutoCloser::new(self.db.clone(), self.gh.clone());
        let votes_auto_closer_handle = votes_auto_closer.run(cancel_token.clone());
        workers_handles.push(votes_auto_closer_handle);

        future::join_all(workers_handles)
    }
}

/// Worker that receives commands from the queue and executes them. Commands