gaohz
/
TakwayBoard
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[client] fix bugs

This commit is contained in:
IrvingGao 2024-06-18 20:30:03 +08:00
parent 9836499b3e
commit 5a300c5140
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
takway/clients/web_socket_client_utils.py
View File

@ -270,6 +270,10 @@ class WebSocketClinet:
# 睡眠 or 监听状态 # 睡眠 or 监听状态
if self.sleep_event.is_set() or self.listening_event.is_set(): if self.sleep_event.is_set() or self.listening_event.is_set():
break break
if self.interrupt_event.is_set():
self.interrupt_event.clear()
print(f"{datetime.now()}: conversation interrupt (input).")
break
if board == 'orangepi': if board == 'orangepi':
recorder.hardware.set_led_off("red") recorder.hardware.set_led_off("red")
# 重新计时 # 重新计时
@ -424,6 +428,7 @@ class WebSocketClinet:
# print(f"listening_event: {self.listening_event.is_set()}, speaking_event: {self.speaking_event.is_set()}") # print(f"listening_event: {self.listening_event.is_set()}, speaking_event: {self.speaking_event.is_set()}")
break # 如果没有接收到消息，则退出循环 break # 如果没有接收到消息，则退出循环
client.close_client() client.close_client()
print(f"{datetime.now()}: web socket client closed.")
def audio_play_process(self): def audio_play_process(self):