File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -142,7 +142,7 @@ async def broadcast_copy(
142142 message_id : int = None ,
143143 text : str = None ,
144144 disable_notification : bool = False ,
145- progress_event : Callable [[int , int ], Awaitable [None ]] = None ,
145+ progress_callback : Callable [[int , int ], Awaitable [None ]] = None ,
146146) -> tuple [int , int ]:
147147 """Рассылка, использующая copy_message или send_message с отслеживанием прогресса.
148148
@@ -153,7 +153,7 @@ async def broadcast_copy(
153153 message_id: Идентификатор сообщения, которое необходимо скопировать.
154154 text: Текст сообщения. (опционально если указаны from_chat_id и message_id).
155155 disable_notification: text: Текст сообщения.
156- progress_event : Callback для отслеживания прогресса рассылки (текущее, общее).
156+ progress_callback : Callback для отслеживания прогресса рассылки (текущее, общее).
157157
158158 Returns:
159159 :return: Кортеж с кол-вом успешных сообщений и ошибок
@@ -183,6 +183,10 @@ async def broadcast_copy(
183183 else :
184184 error_count += 1
185185
186+ # Call progress callback if provided
187+ if progress_callback :
188+ await progress_callback (idx , total )
189+
186190 await asyncio .sleep (
187191 0.05
188192 ) # 20 messages per second (Limit: 30 messages per second)
You can’t perform that action at this time.
0 commit comments