Method execute

crates/consensus/engine/src/task_queue/tasks/insert/task.rs:288–296

(&self, state: &mut EngineState)

    type Error = InsertTaskError;

    async fn execute(&self, state: &mut EngineState) -> Result<(), InsertTaskError> {
        let result = self.insert_payload(state).await;
        if self.result_tx.is_some() {
            self.send_channel_result(result).await;
            Ok(())
        } else {
            result.map(|_| ())
        }
    }
}

#[cfg(test)]