(_, m: Message)
| 256 | @Client.on_message(filters.command(["pause", f"pause@{USERNAME}"]) & filters.group & ~filters.edited) |
| 257 | @authorized_users_only |
| 258 | async def pause(_, m: Message): |
| 259 | chat_id = m.chat.id |
| 260 | |
| 261 | if chat_id in AUDIO_CALL: |
| 262 | await AUDIO_CALL[chat_id].set_audio_pause(True) |
| 263 | await m.reply_text("⏸ **Paused Audio Streaming !**") |
| 264 | |
| 265 | elif chat_id in VIDEO_CALL: |
| 266 | await VIDEO_CALL[chat_id].set_video_pause(True) |
| 267 | await m.reply_text("⏸ **Paused Video Streaming !**") |
| 268 | |
| 269 | else: |
| 270 | await m.reply_text("❌ **Noting Is Streaming !**") |
| 271 | |
| 272 | |
| 273 | @Client.on_message(filters.command(["resume", f"resume@{USERNAME}"]) & filters.group & ~filters.edited) |
nothing calls this directly
no outgoing calls
no test coverage detected