|
@@ -187,7 +187,15 @@ public class WebAiServiceImpl {
|
|
|
// 设置完成回调
|
|
// 设置完成回调
|
|
|
streamingAliyunTtsService.setOnCompleteCallback(() -> {
|
|
streamingAliyunTtsService.setOnCompleteCallback(() -> {
|
|
|
log.info("TTS转换完成,准备终止SSE流");
|
|
log.info("TTS转换完成,准备终止SSE流");
|
|
|
- // 不在这里调用sink.complete(),因为文本处理可能还在进行
|
|
|
|
|
|
|
+ // 调用sink.complete()终止主SSE流
|
|
|
|
|
+ try {
|
|
|
|
|
+ if (!sink.isCancelled()) {
|
|
|
|
|
+ sink.complete();
|
|
|
|
|
+ log.info("主SSE流已成功终止");
|
|
|
|
|
+ }
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
|
+ log.error("终止主SSE流异常", e);
|
|
|
|
|
+ }
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
|
|
|
|
|