From 799fa6330d6fe4be3ef48cf01facc30ab88eede5 Mon Sep 17 00:00:00 2001
From: Maybe Waffle <waffle.lapkin@gmail.com>
Date: Mon, 16 May 2022 21:38:38 +0400
Subject: [PATCH] Remove `log::warn!` from throttle implementation
"Blocking on queue" literally means "nothing is happening, waiting until
something happens". There is no reason to warn users about that.
---
src/adaptors/throttle/worker.rs | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/src/adaptors/throttle/worker.rs b/src/adaptors/throttle/worker.rs
index 92731da6..a3202f4c 100644
--- a/src/adaptors/throttle/worker.rs
+++ b/src/adaptors/throttle/worker.rs
@@ -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,