From 029375c77f5f7d27a7b0e456869eabb03c9a553f Mon Sep 17 00:00:00 2001 From: sxyazi Date: Thu, 25 Apr 2024 17:43:40 +0800 Subject: [PATCH] .. --- yazi-dds/src/body/bulk.rs | 2 +- yazi-dds/src/pubsub.rs | 24 ++++++++++++------------ 2 files changed, 13 insertions(+), 13 deletions(-) diff --git a/yazi-dds/src/body/bulk.rs b/yazi-dds/src/body/bulk.rs index 7cf8f6ee..4e35f1cc 100644 --- a/yazi-dds/src/body/bulk.rs +++ b/yazi-dds/src/body/bulk.rs @@ -21,7 +21,7 @@ impl<'a> BodyBulk<'a> { impl BodyBulk<'static> { #[inline] - pub fn dummy(tab: usize, changes: &HashMap) -> Body<'static> { + pub fn owned(tab: usize, changes: &HashMap) -> Body<'static> { Self { tab, changes: Cow::Owned(changes.clone()) }.into() } } diff --git a/yazi-dds/src/pubsub.rs b/yazi-dds/src/pubsub.rs index 04646de5..2e236ebb 100644 --- a/yazi-dds/src/pubsub.rs +++ b/yazi-dds/src/pubsub.rs @@ -118,18 +118,6 @@ impl Pubsub { } } - pub fn pub_from_bulk(tab: usize, changes: &HashMap) { - 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) { if LOCAL.read().contains_key("rename") { Self::pub_(BodyRename::dummy(tab, from, to)); @@ -142,6 +130,18 @@ impl Pubsub { } } + pub fn pub_from_bulk(tab: usize, changes: &HashMap) { + 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) { if LOCAL.read().contains_key("yank") { Self::pub_(BodyYank::dummy());