Merge pull request #215 from teloxide/remove_warn

Remove `log::warn!` from throttle implementation
This commit is contained in:
Hirrolot 2022-05-17 05:29:24 +06:00 committed by GitHub
commit 0f5fbfeb35
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

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) {
if queue.is_empty() {
log::warn!("A-blocking on queue");
log::debug!("blocking on queue");
match rx.recv().await {
Some(req) => queue.push(req),
None => *rx_is_closed = true,