|
|
@@ -86,22 +86,6 @@ class TestSt:
|
|
|
def send_audio(self, audio_data):
|
|
|
if self.sr:
|
|
|
self.sr.send_audio(audio_data)
|
|
|
- # self.logger.debug("Audio data sent.")
|
|
|
- # if self.sr and not self.is_closed:
|
|
|
- # with self.lock:
|
|
|
- # try:
|
|
|
- # self.sr.send_audio(audio_data)
|
|
|
- # except Exception as e:
|
|
|
- # self.logger.debug(f"Error sending audio: {e}")
|
|
|
- # self.close()
|
|
|
- # def close(self):
|
|
|
- # with self.lock:
|
|
|
- # if not self.is_closed:
|
|
|
- # self.is_closed = True
|
|
|
- # try:
|
|
|
- # self.sr.stop()
|
|
|
- # except Exception as e:
|
|
|
- # self.logger.debug(f"Error stopping ASR: {e}")
|
|
|
|
|
|
def close(self):
|
|
|
try:
|
|
|
@@ -112,6 +96,7 @@ class TestSt:
|
|
|
def __test_run(self):
|
|
|
self.logger.debug("Thread:%s start..",self.__id)
|
|
|
nls.enableTrace(True)
|
|
|
+ count = 0
|
|
|
self.__event.clear()
|
|
|
while not self.__event.is_set():
|
|
|
self.sr = nls.NlsSpeechTranscriber(
|
|
|
@@ -134,7 +119,8 @@ class TestSt:
|
|
|
enable_inverse_text_normalization=True
|
|
|
)
|
|
|
self.sr.ctrl(ex={'max_sentence_silence': '1200ms', 'disfluency': True,'enable_words': True })
|
|
|
- self.logger.debug(f"[{self.__id}]ASR session started.")
|
|
|
+ self.logger.debug(f"[{self.__id}]ASR session started. {count}")
|
|
|
+ count = count + 1
|
|
|
self.__event.wait(timeout=.5)
|
|
|
|
|
|
def test_on_sentence_begin(self, message, *args):
|
Davidliu