fn next(&mut self) -> Option<ExecutionTask> {
        // Send a message to the scheduler requesting the next task be sent.
        match self.tx.send(CoreMessage::Next) {
            Ok(_) => {
                match self.rx.recv() {
                    Ok(task) => Some(task),
                    Err(_) => {
                        // This is expected if the other side shuts down before this
                        // end.
                        None
                    }
                }
            }
            Err(err) => {
                error!(
                    "failed to send request for next in execution task iterator: {}",
                    err
                );
                None
            }
        }
    }
/// Return the next execution task which is available to be executed.
Return the next execution task which is available to be executed.
Return the next execution task which is available to be executed .
fn next(&mut self) -> Option<ExecutionTask> {
        // Send a message to the scheduler requesting the next task be sent.
        match self.tx.send(CoreMessage::Next) {
            Ok(_) => {
                match self.rx.recv() {
                    Ok(task) => Some(task),
                    Err(_) => {
                        // This is expected if the other side shuts down before this
                        // end.
                        None
                    }
                }
            }
            Err(err) => {
                error!(
                    "failed to send request for next in execution task iterator: {}",
                    err
                );
                None
            }
        }
    }
fn next ( & mut self ) -> Option < ExecutionTask > { // Send a message to the scheduler requesting the next task be sent. match self . tx . send ( CoreMessage :: Next ) { Ok ( _ ) => { match self . rx . recv ( ) { Ok ( task ) => Some ( task ) , Err ( _ ) => { // This is expected if the other side shuts down before this // end. None } } } Err ( err ) => { error ! ( " " err ) ; None } } }
Return the next execution task which is available to be executed.
Return the next execution task which is available to be executed .
&mut self
&mut self