Method new

src/executors/delay_executor.rs:99–167

(executor: Executor)

impl DelayExecutor {
    pub(crate) fn new(executor: Executor) -> (Self, DelayTX) {
        let (tx, mut rx) = tokio::sync::mpsc::channel::<Command>(10);
        let (skip_tx, mut skip_rx) = tokio::sync::mpsc::channel::<()>(10);
        let (clear_tx, mut clear_rx) = tokio::sync::mpsc::channel::<()>(10);

        let timer = slint::Timer::default();
        let command = Arc::new(RwLock::new(VecDeque::new()));
        let command_clone = command.clone();

        let executor = Self {
            timer,
            executor,
            command,
        };
        tokio::spawn(async move {
            let mut current_figure: VecDeque<Command> = VecDeque::new();

            loop {
                tokio::select! {
                    Some(figure) = rx.recv()=> {
                        current_figure.push_back(figure);
                    }

                    // 延迟完成
                    _ = async {
                        if let Some(Command::Figure {delay, ..})
                        | Some(Command::Move {delay, ..}) = current_figure.front(){
                            sleep(Duration::from_millis(
                                delay.clone().unwrap_or_default().parse::<u64>().unwrap_or(0),
                            )).await;
                        } else {
                            std::future::pending::<()>().await
                        }
                    } => {
                        if let Some(cmd) = current_figure.pop_front() {
                            command_clone.write().unwrap().push_back(cmd);
                        }
                    }

                    // 重置请求
                    _ = skip_rx.recv() => {
                        while let Some(figure) = current_figure.pop_front() {
                            if let Command::Figure {..} = figure {
                                command_clone.write().unwrap().push_back(figure);
                            } else if let Command::Move {..} = figure {
                                if figure.action() != "nod" {
                                    command_clone.write().unwrap().push_back(figure)
                                }
                            }
                        }
                    }

                    // 清空请求
                    _ = clear_rx.recv() => {
                        current_figure.clear();
                    }
                }
            }