..

yazi-core/src/event.rs

@@ -6,7 +6,7 @@ use yazi_config::open::Opener;
 use yazi_shared::{fs::Url, term::Term, Exec, Layer, RoCell};
 
 use super::files::FilesOp;
-use crate::{preview::PreviewLock, tasks::TasksProgress};
+use crate::preview::PreviewLock;
 
 static TX: RoCell<UnboundedSender<Event>> = RoCell::new();
 
@@ -25,11 +25,8 @@ pub enum Event {
 	Mimetype(BTreeMap<Url, String>),
 	Preview(PreviewLock),
 
-	// Input(InputOpt, mpsc::UnboundedSender<Result<String, InputError>>),
-
 	// Tasks
 	Open(Vec<(OsString, String)>, Option<Opener>),
-	Progress(TasksProgress),
 }
 
 impl Event {
@@ -83,9 +80,6 @@ macro_rules! emit {
 	(Open($targets:expr, $opener:expr)) => {
 		$crate::Event::Open($targets, $opener).emit();
 	};
-	(Progress($progress:expr)) => {
-		$crate::Event::Progress($progress).emit();
-	};
 
 	($event:ident) => {
 		$crate::Event::$event.emit();

yazi-core/src/input/commands/show.rs

@@ -1,4 +1,4 @@
-use anyhow::bail;
+use anyhow::anyhow;
 use tokio::sync::mpsc;
 use yazi_config::popup::InputCfg;
 use yazi_shared::{Exec, InputError, Layer};
@@ -14,13 +14,7 @@ impl TryFrom<&Exec> for Opt {
 	type Error = anyhow::Error;
 
 	fn try_from(e: &Exec) -> Result<Self, Self::Error> {
-		let Some(data) = e.data.borrow_mut().take() else {
+		e.take_data().ok_or_else(|| anyhow!("invalid data"))
-			bail!("missing data");
-		};
-		let Ok(opt) = data.downcast::<Opt>() else {
-			bail!("invalid data");
-		};
-		Ok(*opt)
 	}
 }
 

yazi-core/src/select/commands/show.rs

@@ -1,4 +1,4 @@
-use anyhow::{bail, Result};
+use anyhow::{anyhow, Result};
 use tokio::sync::oneshot;
 use yazi_config::popup::SelectCfg;
 use yazi_shared::{term::Term, Exec, Layer};
@@ -14,13 +14,7 @@ impl TryFrom<&Exec> for Opt {
 	type Error = anyhow::Error;
 
 	fn try_from(e: &Exec) -> Result<Self, Self::Error> {
-		let Some(data) = e.data.borrow_mut().take() else {
+		e.take_data().ok_or_else(|| anyhow!("invalid data"))
-			bail!("missing data");
-		};
-		let Ok(opt) = data.downcast::<Opt>() else {
-			bail!("invalid data");
-		};
-		Ok(*opt)
 	}
 }
 

yazi-core/src/tasks/commands/mod.rs

@@ -2,3 +2,4 @@ mod arrow;
 mod cancel;
 mod inspect;
 mod toggle;
+mod update;

yazi-core/src/tasks/commands/update.rs

@@ -0,0 +1,31 @@
+use anyhow::anyhow;
+use yazi_shared::{Exec, Layer};
+
+use crate::{emit, tasks::{Tasks, TasksProgress}};
+
+pub struct Opt {
+	progress: TasksProgress,
+}
+
+impl TryFrom<&Exec> for Opt {
+	type Error = anyhow::Error;
+
+	fn try_from(e: &Exec) -> Result<Self, Self::Error> {
+		e.take_data().ok_or_else(|| anyhow!("invalid data"))
+	}
+}
+
+impl Tasks {
+	pub fn _update(progress: TasksProgress) {
+		emit!(Call(Exec::call("update", vec![]).with_data(Opt { progress }).vec(), Layer::Tasks));
+	}
+
+	pub fn update(&mut self, opt: impl TryInto<Opt>) -> bool {
+		let Ok(opt) = opt.try_into() else {
+			return false;
+		};
+
+		self.progress = opt.progress;
+		true
+	}
+}

yazi-core/src/tasks/scheduler.rs

@@ -7,7 +7,7 @@ use yazi_config::{open::Opener, TASKS};
 use yazi_shared::{fs::{unique_path, Url}, Throttle};
 
 use super::{workers::{File, FileOpDelete, FileOpLink, FileOpPaste, FileOpTrash, Precache, PrecacheOpMime, PrecacheOpSize, Process, ProcessOpOpen}, Running, TaskOp, TaskStage, TasksProgress};
-use crate::emit;
+use crate::tasks::Tasks;
 
 pub struct Scheduler {
 	file:     Arc<File>,
@@ -157,7 +157,7 @@ impl Scheduler {
 				let new = TasksProgress::from(&*running.read());
 				if last != new {
 					last = new;
-					emit!(Progress(new));
+					Tasks::_update(new);
 				}
 			}
 		});

yazi-fm/src/app.rs

@@ -195,10 +195,6 @@ impl App {
 					tasks.file_open(&targets);
 				}
 			}
-			Event::Progress(progress) => {
-				tasks.progress = progress;
-				emit!(Render);
-			}
 
 			_ => unreachable!(),
 		}

yazi-fm/src/executor.rs

@@ -163,6 +163,7 @@ impl<'a> Executor<'a> {
 			};
 		}
 
+		on!(update);
 		on!(toggle, "close");
 		on!(arrow);
 		on!(inspect);

yazi-shared/src/event.rs

@@ -41,6 +41,11 @@ impl Exec {
 		self.data = RefCell::new(Some(Box::new(data)));
 		self
 	}
+
+	#[inline]
+	pub fn take_data<T: 'static>(&self) -> Option<T> {
+		self.data.replace(None).and_then(|d| d.downcast::<T>().ok()).map(|d| *d)
+	}
 }
 
 impl Display for Exec {