TTS

src/main/java/com/telerobot/fs/robot/AbstractChatRobot.java

@@ -116,6 +116,10 @@ public abstract class AbstractChatRobot implements IChatRobot {
         return isTxTts1Provider() || isViiTorProvider();
     }
 
+    protected boolean canFlushResumeWhileTryingOpen() {
+        return isTxTts1Provider();
+    }
+
     protected boolean isTxTts1FlushBoundary(String input) {
         if (StringUtils.isEmpty(input)) {
             return false;
@@ -230,7 +234,7 @@ public abstract class AbstractChatRobot implements IChatRobot {
             flushTtsRequestQueue();
         }else  if(TtsChannelState.TRYING_OPEN.getCode().equals(ttsChannelState.getCode()))  {
             ttsRequestQueue.add(text);
-            if (isResumeStreamingProvider()) {
+            if (canFlushResumeWhileTryingOpen()) {
                 flushTtsRequestQueue();
             }
         }
@@ -292,7 +296,7 @@ public abstract class AbstractChatRobot implements IChatRobot {
             flushTtsRequestQueue();
         }else  if(TtsChannelState.TRYING_OPEN.getCode().equals(ttsChannelState.getCode()))  {
             ttsRequestQueue.add(cmd);
-            if (isResumeStreamingProvider()) {
+            if (canFlushResumeWhileTryingOpen()) {
                 flushTtsRequestQueue();
             }
         }
@@ -303,7 +307,7 @@ public abstract class AbstractChatRobot implements IChatRobot {
         if (TtsChannelState.OPENED.getCode().equals(ttsChannelState.getCode())) {
             return true;
         }
-        return isResumeStreamingProvider() && TtsChannelState.TRYING_OPEN.getCode().equals(ttsChannelState.getCode());
+        return canFlushResumeWhileTryingOpen() && TtsChannelState.TRYING_OPEN.getCode().equals(ttsChannelState.getCode());
     }
 
     private void sendTtsResumeCommand(String text) {