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

[bug] board

This commit is contained in:
IrvingGao 2024-05-23 18:03:09 +08:00
parent df34eab33a
commit 6a9edd9139
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
takway/clients/web_socket_client_utils.py
View File

@ -328,12 +328,17 @@ class WebSocketClinet:
# 第一级：唤醒状态下，连接服务器 # 第一级：唤醒状态下，连接服务器
if self.wakeup_event.is_set(): if self.wakeup_event.is_set():
client.wakeup_client() client.wakeup_client()
clear_queue_flag = False
else: else:
print(f"not wake up, skip setup web socket connection.") print(f"not wake up, skip setup web socket connection.")
self.client_queue.get(block=False) self.client_queue.get(block=False)
continue continue
# 播放状态下，不连接服务器
if self.speaking_event.is_set():
print(f"speaking, skip setup web socket connection.")
self.client_queue.get(block=False)
continue
# 发送数据 # 发送数据
for queue_data in QueueIterator(self.client_queue): for queue_data in QueueIterator(self.client_queue):
# 发送音频数据 # 发送音频数据
@ -396,6 +401,8 @@ class WebSocketClinet:
# 切换播放模式 # 切换播放模式
self.listening_event.clear() self.listening_event.clear()
self.speaking_event.set() self.speaking_event.set()
if response['type'] == 'close':
break
elif data_type == bytes: elif data_type == bytes:
# 开始播放 # 开始播放
print(f"{datetime.now()}: receive audio data") print(f"{datetime.now()}: receive audio data")