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 17:31:00 +08:00
parent b431f2611b
commit 1e037854fd
1 changed files with 4 additions and 1 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

@ -370,6 +370,9 @@ class WebSocketClinet:
client.close_client() client.close_client()
break break
if self.interrupt_event.is_set():
break
response, data_type = client.receive_per_data() response, data_type = client.receive_per_data()
if data_type == dict: if data_type == dict:
print(f"{datetime.now()}: receive json data: {response}") # 打印接收到的消息 print(f"{datetime.now()}: receive json data: {response}") # 打印接收到的消息
@ -408,6 +411,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()
self.interrupt_event.clear()
def audio_play_process(self): def audio_play_process(self):
@ -462,7 +466,6 @@ class WebSocketClinet:
time.sleep(0.5) time.sleep(0.5)
self.listening_event.set() self.listening_event.set()
self.speaking_event.clear() self.speaking_event.clear()
self.interrupt_event.clear()
break break
# if self.listening_event.is_set() and not self.speaking_event.is_set(): # if self.listening_event.is_set() and not self.speaking_event.is_set():
# print(f"{datetime.now()}: speaker interrupt.") # print(f"{datetime.now()}: speaker interrupt.")