OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2025-01-07 02:59:41 +01:00
Code Issues Projects Releases Packages Wiki Activity

Fix Clippy

Browse source
This commit is contained in:
Temirkhan Myrzamadi 2021-02-16 02:03:04 +06:00
parent 65c98741db
commit 8deaac04fa
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/adaptors/throttle.rs
View file

@ -259,9 +259,9 @@ async fn worker(limits: Limits, mut rx: mpsc::Receiver<(ChatIdHash, Sender<Never
while let Some(entry) = queue_removing.next() {
let chat = &entry.value().0;
let requests_sent = requests_sent.per_sec.get(chat).copied().unwrap_or(0);
let limits_not_exceeded = requests_sent < limits.messages_per_sec_chat
&& requests_sent < limits.messages_per_min_chat;
let requests_sent_count = requests_sent.per_sec.get(chat).copied().unwrap_or(0);
let limits_not_exceeded = requests_sent_count < limits.messages_per_sec_chat
&& requests_sent_count < limits.messages_per_min_chat;
if limits_not_exceeded {
*requests_sent.per_sec.entry(*chat).or_insert(0) += 1;