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

Remove log::warn! from throttle implementation

Browse source 
"Blocking on queue" literally means "nothing is happening, waiting until
something happens". There is no reason to warn users about that.
This commit is contained in:
Maybe Waffle 2022-05-16 21:38:38 +04:00
parent a951d4d544
commit 799fa6330d
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/adaptors/throttle/worker.rs
View file

@ -359,7 +359,8 @@ async fn freeze(
async fn read_from_rx<T>(rx: &mut mpsc::Receiver<T>, queue: &mut Vec<T>, rx_is_closed: &mut bool) { async fn read_from_rx<T>(rx: &mut mpsc::Receiver<T>, queue: &mut Vec<T>, rx_is_closed: &mut bool) {
if queue.is_empty() { if queue.is_empty() {
log::warn!("A-blocking on queue"); log::debug!("blocking on queue");
match rx.recv().await { match rx.recv().await {
Some(req) => queue.push(req), Some(req) => queue.push(req),
None => *rx_is_closed = true, None => *rx_is_closed = true,