diff --git a/takway/clients/web_socket_client_utils.py b/takway/clients/web_socket_client_utils.py index f2dc218..47b3fde 100644 --- a/takway/clients/web_socket_client_utils.py +++ b/takway/clients/web_socket_client_utils.py @@ -270,6 +270,10 @@ class WebSocketClinet: # 睡眠 or 监听状态 if self.sleep_event.is_set() or self.listening_event.is_set(): break + if self.interrupt_event.is_set(): + self.interrupt_event.clear() + print(f"{datetime.now()}: conversation interrupt (input).") + break if board == 'orangepi': recorder.hardware.set_led_off("red") # 重新计时 @@ -424,6 +428,7 @@ class WebSocketClinet: # print(f"listening_event: {self.listening_event.is_set()}, speaking_event: {self.speaking_event.is_set()}") break # 如果没有接收到消息,则退出循环 client.close_client() + print(f"{datetime.now()}: web socket client closed.") def audio_play_process(self):