Method new

src/executors/text_executor.rs:14–55

(weak: Weak<MainWindow>)

impl TextExecutor {
    pub(crate) fn new(weak: Weak<MainWindow>) -> (Self, Sender<Arc<RwLock<DisplayText>>>) {
        let (full_text_tx, mut full_text_rx) = channel::<Arc<RwLock<DisplayText>>>(10);
        let (text_tx, text_rx) = std::sync::mpsc::channel::<String>();
        let timer = slint::Timer::default();

        let executor = Self {
            timer,
            weak,
            text_rx: Some(text_rx),
        };

        tokio::spawn(async move {
            while let Some(text) = full_text_rx.recv().await {
                let speed = text.read().unwrap().speed;
                if speed == Duration::from_millis(0) {
                    let mut text = text.write().unwrap();
                    let tx = text_tx.clone();
                    if let Err(e) = tx.send(text.full_text.clone()) {
                        eprintln!("text channel closed: {e}");
                        return;
                    }
                    text.is_running = false;
                    continue;
                }
                while text.read().unwrap().is_running {
                    let tx = text_tx.clone();
                    {
                        let mut text = text.write().unwrap();
                        if let Some(text) = text.next_character() {
                            if let Err(e) = tx.send(text) {
                                eprintln!("text channel closed: {e}");
                                return;
                            }
                        }
                    }
                    sleep(speed).await;
                }
            }
        });

        (executor, full_text_tx)
    }

    pub(crate) fn start_timer(&mut self) {
        let weak = self.weak.clone();