async fn process_next_job(&mut self) {
        // Iterate through sources and see if any source has a pending job
        for (source_id, source_handler) in &mut self.sources.iter_mut() {
            let source_id = *source_id;
            let execution_tx = self.execution_completion_sender.clone();

            source_handler
                .execute_next(&mut self.message_hub_delegate, move |job_info, details| {
                    if let Err(error) = execution_tx.unbounded_send((source_id, job_info, details))
                    {
                        panic!("Failed to send message. error: {:?}", error);
                    };
                })
                .await;
        }
    }
// Executes the next job if conditions to run another job are met. If so, the manager consults
// available sources for a candidate job and then executes the first one found.
Executes the next job if conditions to run another job are met. If so, the manager consults
available sources for a candidate job and then executes the first one found.
Executes the next job if conditions to run another job are met . If so the manager consults available sources for a candidate job and then executes the first one found .
async fn process_next_job(&mut self) {
        // Iterate through sources and see if any source has a pending job
        for (source_id, source_handler) in &mut self.sources.iter_mut() {
            let source_id = *source_id;
            let execution_tx = self.execution_completion_sender.clone();
            source_handler
                .execute_next(&mut self.message_hub_delegate, move |job_info, details| {
                    if let Err(error) = execution_tx.unbounded_send((source_id, job_info, details))
                    {
                        panic!("Failed to send message. error: {:?}", error);
                    };
                })
                .await;
        }
    }
async fn process_next_job ( & mut self ) { // Iterate through sources and see if any source has a pending job for ( source_id , source_handler ) in & mut self . sources . iter_mut ( ) { let source_id = * source_id ; let execution_tx = self . execution_completion_sender . clone ( ) ; source_handler . execute_next ( & mut self . message_hub_delegate , move | job_info , details | { if let Err ( error ) = execution_tx . unbounded_send ( ( source_id , job_info , details ) ) { panic ! ( " " error ) ; } ; } ) . await ; } }
Executes the next job if conditions to run another job are met.
Executes the next job if conditions to run another job are met .
&mut self
&mut self