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 16:31:48 +08:00
parent 2d794a271e
commit 4c60b07df1
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
takway/clients/web_socket_client_utils.py
View File

@ -362,8 +362,9 @@ class WebSocketClinet:
continue continue
elif data_type == bytes: elif data_type == bytes:
# 开始播放 # 开始播放
self.speaking_event.set() if self.listening_event.is_set():
self.listening_event.clear() self.speaking_event.set()
self.listening_event.clear()
print(f"{datetime.now()}: receive audio data") print(f"{datetime.now()}: receive audio data")
self.audio_play_queue.put(('audio_bytes', response)) self.audio_play_queue.put(('audio_bytes', response))
elif data_type == None: elif data_type == None:
@ -406,7 +407,7 @@ class WebSocketClinet:
tts_audio = audio_player.check_audio_type(tts_audio, return_type=None) tts_audio = audio_player.check_audio_type(tts_audio, return_type=None)
for i in range(0, len(tts_audio), audio_player.CHUNK): for i in range(0, len(tts_audio), audio_player.CHUNK):
audio_player.stream.write(tts_audio[i:i+audio_player.CHUNK]) audio_player.stream.write(tts_audio[i:i+audio_player.CHUNK])
# print("Playing {} data...{}/{}".format(item[0], i, len(tts_audio))) print("Playing {} data...{}/{}".format(item[0], i, len(tts_audio)))
# 按键打断播放 # 按键打断播放
if self.interrupt_event.is_set(): if self.interrupt_event.is_set():