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

            // Ignore the executed status.
            let _ = 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);
                        };
                    },
                    nonce,
                )
                .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, nonce: TracingNonce) {
        // Iterate through sources and see if any source has a pending job
        for (source_id, source_handler) in &mut self.sources {
            let source_id = *source_id;
            let execution_tx = self.execution_completion_sender.clone();
            // Ignore the executed status.
            let _ = 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);
                        };
                    },
                    nonce,
                )
                .await;
        }
    }
async fn process_next_job ( & mut self , nonce : TracingNonce ) { // Iterate through sources and see if any source has a pending job for ( source_id , source_handler ) in & mut self . sources { let source_id = * source_id ; let execution_tx = self . execution_completion_sender . clone ( ) ; // Ignore the executed status. let _ = 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 ) ; } ; } , nonce , ) . 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
nonce
TracingNonce
&mut self
nonce
TracingNonce