OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2024-12-22 22:46:39 +01:00
Code Issues Projects Releases Packages Wiki Activity

Apply suggestions from the review

Browse source 
Former-commit-id: 8489464bd3
This commit is contained in:
Maybe Waffle 2022-06-27 00:01:31 +04:00
parent 0b307aa177
commit 98a892e6bd
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);
loop {
self.gc_workers_if_needed().await;
self.remove_inactive_workers_if_needed().await;
// False positive
#[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 max = self.max_number_of_active_workers.load(Ordering::Relaxed) as usize;
@ -387,11 +387,11 @@ where
return;
}
self.gc_workers().await;
self.remove_inactive_workers().await;
}
#[inline(never)]
async fn gc_workers(&mut self) {
#[inline(never)] // Cold function.
async fn remove_inactive_workers(&mut self) {
let handles = self
.workers
.iter()