diff --git a/takway/clients/web_socket_client_utils.py b/takway/clients/web_socket_client_utils.py index 3147b13..016c38c 100644 --- a/takway/clients/web_socket_client_utils.py +++ b/takway/clients/web_socket_client_utils.py @@ -362,8 +362,9 @@ class WebSocketClinet: continue elif data_type == bytes: # 开始播放 - self.speaking_event.set() - self.listening_event.clear() + if self.listening_event.is_set(): + self.speaking_event.set() + self.listening_event.clear() print(f"{datetime.now()}: receive audio data") self.audio_play_queue.put(('audio_bytes', response)) elif data_type == None: @@ -406,7 +407,7 @@ class WebSocketClinet: tts_audio = audio_player.check_audio_type(tts_audio, return_type=None) for i in range(0, len(tts_audio), 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():