mroot/yazi
1
0
Fork 0
mirror of https://github.com/sxyazi/yazi.git synced 2026-07-25 08:41:05 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

..

Browse source
This commit is contained in:
sxyazi 2024-04-25 17:43:40 +08:00
parent 65003337f9
commit 029375c77f
No known key found for this signature in database
2 changed files with 13 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
yazi-dds/src/body/bulk.rs
View file

@ -21,7 +21,7 @@ impl<'a> BodyBulk<'a> {
impl BodyBulk<'static> { impl BodyBulk<'static> {
#[inline] #[inline]
pub fn dummy(tab: usize, changes: &HashMap<Url, Url>) -> Body<'static> { pub fn owned(tab: usize, changes: &HashMap<Url, Url>) -> Body<'static> {
Self { tab, changes: Cow::Owned(changes.clone()) }.into() Self { tab, changes: Cow::Owned(changes.clone()) }.into()
} }
} }

24
yazi-dds/src/pubsub.rs
View file

@ -118,18 +118,6 @@ impl Pubsub {
} }
} }
pub fn pub_from_bulk(tab: usize, changes: &HashMap<Url, Url>) {
if LOCAL.read().contains_key("bulk") {
Self::pub_(BodyBulk::dummy(tab, changes));
}
if PEERS.read().values().any(|p| p.able("bulk")) {
Client::push(BodyBulk::borrowed(tab, changes));
}
if BOOT.local_events.contains("bulk") {
BodyBulk::borrowed(tab, changes).with_receiver(*ID).flush();
}
}
pub fn pub_from_rename(tab: usize, from: &Url, to: &Url) { pub fn pub_from_rename(tab: usize, from: &Url, to: &Url) {
if LOCAL.read().contains_key("rename") { if LOCAL.read().contains_key("rename") {
Self::pub_(BodyRename::dummy(tab, from, to)); Self::pub_(BodyRename::dummy(tab, from, to));
@ -142,6 +130,18 @@ impl Pubsub {
} }
} }
pub fn pub_from_bulk(tab: usize, changes: &HashMap<Url, Url>) {
if LOCAL.read().contains_key("bulk") {
Self::pub_(BodyBulk::owned(tab, changes));
}
if PEERS.read().values().any(|p| p.able("bulk")) {
Client::push(BodyBulk::borrowed(tab, changes));
}
if BOOT.local_events.contains("bulk") {
BodyBulk::borrowed(tab, changes).with_receiver(*ID).flush();
}
}
pub fn pub_from_yank(cut: bool, urls: &HashSet<Url>) { pub fn pub_from_yank(cut: bool, urls: &HashSet<Url>) {
if LOCAL.read().contains_key("yank") { if LOCAL.read().contains_key("yank") {
Self::pub_(BodyYank::dummy()); Self::pub_(BodyYank::dummy());