From f894ffb295ae6d37245165c3abe20db593e69867 Mon Sep 17 00:00:00 2001 From: Stephan Dilly Date: Wed, 20 May 2020 18:11:48 +0200 Subject: [PATCH] clippy fix --- asyncgit/src/revlog.rs | 28 +++++++++++++--------------- 1 file changed, 13 insertions(+), 15 deletions(-) diff --git a/asyncgit/src/revlog.rs b/asyncgit/src/revlog.rs index 68ddf48c..44c13444 100644 --- a/asyncgit/src/revlog.rs +++ b/asyncgit/src/revlog.rs @@ -80,24 +80,22 @@ impl AsyncLog { /// pub fn fetch(&mut self) -> Result<()> { - if !self.is_pending() { - if self.head_changed()? { - self.clear()?; + if !self.is_pending() && self.head_changed()? { + self.clear()?; - let arc_current = Arc::clone(&self.current); - let sender = self.sender.clone(); - let arc_pending = Arc::clone(&self.pending); + let arc_current = Arc::clone(&self.current); + let sender = self.sender.clone(); + let arc_pending = Arc::clone(&self.pending); - rayon_core::spawn(move || { - scope_time!("async::revlog"); + rayon_core::spawn(move || { + scope_time!("async::revlog"); - arc_pending.store(true, Ordering::Relaxed); - AsyncLog::fetch_helper(arc_current, &sender) - .expect("failed to fetch"); - arc_pending.store(false, Ordering::Relaxed); - Self::notify(&sender); - }); - } + arc_pending.store(true, Ordering::Relaxed); + AsyncLog::fetch_helper(arc_current, &sender) + .expect("failed to fetch"); + arc_pending.store(false, Ordering::Relaxed); + Self::notify(&sender); + }); } Ok(()) }