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

[event] fix bugs

This commit is contained in:
IrvingGao 2024-06-18 22:25:52 +08:00
parent cc5009f368
commit 4044e2b3e6
1 changed files with 5 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
takway/clients/web_socket_client_utils.py
View File

@ -386,8 +386,8 @@ class WebSocketClinet:
if not self.wakeup_event.is_set(): if not self.wakeup_event.is_set():
continue continue
if self.listening_event.is_set(): if self.listening_event.is_set() or self.speaking_event.is_set():
print(f"{datetime.now()}: listening, skip setup web socket connection.") print(f"{datetime.now()}: listening or speaking, skip setup web socket connection.")
continue continue
# 接收数据 # 接收数据
@ -399,11 +399,6 @@ class WebSocketClinet:
client.close_client() client.close_client()
break break
# if self.interrupt_event.is_set():
# self.listening_event.set()
# self.speaking_event.clear()
# 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}") # 打印接收到的消息
@ -431,10 +426,6 @@ class WebSocketClinet:
self.speaking_event.set() self.speaking_event.set()
self.audio_play_queue.put(('text_audio_data', response)) self.audio_play_queue.put(('text_audio_data', response))
elif data_type == bytes:
# 开始播放
print(f"{datetime.now()}: receive audio bytes")
self.audio_play_queue.put(('audio_bytes', response))
elif data_type == None: elif data_type == None:
print(f"{datetime.now()}: receive None data, break loop.") print(f"{datetime.now()}: receive None data, break loop.")
# 切换录音模式 # 切换录音模式
@ -540,7 +531,7 @@ class WebSocketClinet:
"""
def excute_process(self): def excute_process(self):
''' '''
Args: Args:
@ -562,4 +553,5 @@ class WebSocketClinet:
self.audio_play_queue.put((instruct, content)) self.audio_play_queue.put((instruct, content))
self.speaker_active_set.clear() self.speaker_active_set.clear()
"""