From 6f645e609acc6dca77211e81522c37c588f71a8e Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Tue, 2 Apr 2024 20:01:36 +0200 Subject: [PATCH] Fix --- src/bots_manager/mod.rs | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/bots_manager/mod.rs b/src/bots_manager/mod.rs index b7ad402..f1668f6 100644 --- a/src/bots_manager/mod.rs +++ b/src/bots_manager/mod.rs @@ -15,6 +15,7 @@ use std::sync::Arc; use smallvec::SmallVec; use tokio::time::{self, sleep, Duration}; +use tokio::sync::Semaphore; use teloxide::prelude::*; @@ -83,6 +84,7 @@ impl BotsManager { } }; + let semaphore = Arc::new(Semaphore::const_new(10)); let mut set_webhook_tasks = JoinSet::new(); for bot_data in bots_data.iter() { @@ -96,8 +98,13 @@ impl BotsManager { let bot_data = bot_data.clone(); + let semphore = semaphore.clone(); set_webhook_tasks.spawn(async move { + let _permit = semphore.acquire().await.unwrap(); + set_webhook(&bot_data).await; + + drop(_permit); }); }