OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2025-01-09 11:43:57 +01:00
Code Issues Projects Releases Packages Wiki Activity

Apply suggestions from the review

Browse source
This commit is contained in:
Maybe Waffle 2022-06-27 00:01:31 +04:00
parent a820dedd50
commit 8489464bd3
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/dispatching/dispatcher.rs
View file

@ -288,7 +288,7 @@ where
tokio::pin!(stream); tokio::pin!(stream);
loop { loop {
self.gc_workers_if_needed().await; self.remove_inactive_workers_if_needed().await;
// False positive // False positive
#[allow(clippy::collapsible_match)] #[allow(clippy::collapsible_match)]
@ -379,7 +379,7 @@ where
} }
} }
async fn gc_workers_if_needed(&mut self) { async fn remove_inactive_workers_if_needed(&mut self) {
let workers = self.workers.len(); let workers = self.workers.len();
let max = self.max_number_of_active_workers.load(Ordering::Relaxed) as usize; let max = self.max_number_of_active_workers.load(Ordering::Relaxed) as usize;
@ -387,11 +387,11 @@ where
return; return;
} }
self.gc_workers().await; self.remove_inactive_workers().await;
} }
#[inline(never)] #[inline(never)] // Cold function.
async fn gc_workers(&mut self) { async fn remove_inactive_workers(&mut self) {
let handles = self let handles = self
.workers .workers
.iter() .iter()