Xtao-Labs/video-stream
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fixes

Browse Source
This commit is contained in:
levina 2022-02-08 00:00:51 +07:00 committed by GitHub
parent 42fed3cd54
commit 72b6da8a31
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
driver/utils.py
View File

@ -86,25 +86,25 @@ async def skip_item(chat_id, h):
return 0 return 0
@call_py.on_kicked() @calls.on_kicked()
async def kicked_handler(_, chat_id: int): async def kicked_handler(_, chat_id: int):
if chat_id in QUEUE: if chat_id in QUEUE:
clear_queue(chat_id) clear_queue(chat_id)
@call_py.on_closed_voice_chat() @calls.on_closed_voice_chat()
async def closed_voice_chat_handler(_, chat_id: int): async def closed_voice_chat_handler(_, chat_id: int):
if chat_id in QUEUE: if chat_id in QUEUE:
clear_queue(chat_id) clear_queue(chat_id)
@call_py.on_left() @calls.on_left()
async def left_handler(_, chat_id: int): async def left_handler(_, chat_id: int):
if chat_id in QUEUE: if chat_id in QUEUE:
clear_queue(chat_id) clear_queue(chat_id)
@call_py.on_stream_end() @calls.on_stream_end()
async def stream_end_handler(_, u: Update): async def stream_end_handler(_, u: Update):
if isinstance(u, StreamAudioEnded): if isinstance(u, StreamAudioEnded):
chat_id = u.chat_id chat_id = u.chat_id