mirror of
https://github.com/sxyazi/yazi.git
synced 2026-07-25 08:41:05 +00:00
perf: do not listen for file changes in inactive tabs
This commit is contained in:
parent
52ecb31f5a
commit
b9b14f3583
5 changed files with 15 additions and 19 deletions
|
|
@ -1,4 +1,4 @@
|
|||
use std::collections::HashSet;
|
||||
use std::iter;
|
||||
|
||||
use yazi_parser::mgr::WatchOpt;
|
||||
|
||||
|
|
@ -6,17 +6,11 @@ use crate::mgr::Mgr;
|
|||
|
||||
impl Mgr {
|
||||
#[yazi_codegen::command]
|
||||
pub fn watch(&mut self, _: WatchOpt) {
|
||||
let mut to_watch = HashSet::with_capacity(3 * self.tabs.len());
|
||||
for tab in self.tabs.iter() {
|
||||
to_watch.insert(tab.cwd());
|
||||
if let Some(ref p) = tab.parent {
|
||||
to_watch.insert(&p.url);
|
||||
}
|
||||
if let Some(h) = tab.hovered().filter(|&h| h.is_dir()) {
|
||||
to_watch.insert(&h.url);
|
||||
}
|
||||
}
|
||||
self.watcher.watch(to_watch);
|
||||
pub fn watch(&mut self, _: Opt) {
|
||||
let it = iter::once(self.tabs.active().cwd())
|
||||
.chain(self.tabs.parent().map(|p| &p.url))
|
||||
.chain(self.tabs.hovered().filter(|h| h.is_dir()).map(|h| &h.url));
|
||||
|
||||
self.watcher.watch(it);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -51,6 +51,9 @@ impl Tabs {
|
|||
#[inline]
|
||||
pub(super) fn active_mut(&mut self) -> &mut Tab { &mut self.items[self.cursor] }
|
||||
|
||||
#[inline]
|
||||
pub fn parent(&self) -> Option<&Folder> { self.active().parent.as_ref() }
|
||||
|
||||
#[inline]
|
||||
pub fn current(&self) -> &Folder { &self.active().current }
|
||||
|
||||
|
|
|
|||
|
|
@ -51,9 +51,8 @@ impl Watcher {
|
|||
Self { in_tx, out_tx }
|
||||
}
|
||||
|
||||
pub(super) fn watch(&mut self, mut new: HashSet<&Url>) {
|
||||
new.retain(|&u| u.is_regular());
|
||||
self.in_tx.send(new.into_iter().cloned().collect()).ok();
|
||||
pub(super) fn watch<'a>(&mut self, it: impl Iterator<Item = &'a Url>) {
|
||||
self.in_tx.send(it.into_iter().filter(|u| u.is_regular()).cloned().collect()).ok();
|
||||
}
|
||||
|
||||
pub(super) fn push_files(&self, urls: Vec<Url>) {
|
||||
|
|
|
|||
|
|
@ -8,7 +8,7 @@ function M:peek(job)
|
|||
return require("empty").msg(
|
||||
job,
|
||||
code == 2 and "File list in this archive is encrypted"
|
||||
or "Failed to start both `7zz` and `7z`. Do you have 7-zip installed?"
|
||||
or "Failed to start either `7zz` or `7z`. Do you have 7-zip installed?"
|
||||
)
|
||||
end
|
||||
|
||||
|
|
@ -65,7 +65,7 @@ function M.spawn_7z(args)
|
|||
|
||||
local child = try("7zz") or try("7z")
|
||||
if not child then
|
||||
return ya.err("Failed to start both `7zz` and `7z`, error: " .. last_err)
|
||||
return ya.err("Failed to start either `7zz` or `7z`, error: " .. last_err)
|
||||
end
|
||||
return child, last_err
|
||||
end
|
||||
|
|
|
|||
|
|
@ -53,7 +53,7 @@ function M:try_with(from, pwd, to)
|
|||
local archive = require("archive")
|
||||
local child, err = archive.spawn_7z { "x", "-aou", "-sccUTF-8", "-p" .. pwd, "-o" .. tostring(tmp), tostring(from) }
|
||||
if not child then
|
||||
fail("Failed to start both `7zz` and `7z`, error: " .. err)
|
||||
fail("Failed to start either `7zz` or `7z`, error: " .. err)
|
||||
end
|
||||
|
||||
local output, err = child:wait_with_output()
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue