|
@@ -76,7 +76,7 @@ public class KimiChatServiceImpl extends ServiceImpl<KimiChatMapper, KimiChat> i
|
|
|
.thenApply(HttpResponse::body)
|
|
|
.thenAccept(x -> {
|
|
|
log.info("流数据 -- ",x);
|
|
|
- if(!TextUtils.isEmpty(x.trim())){
|
|
|
+ if(!TextUtils.isEmpty(x.replaceAll("\n", "").trim())){
|
|
|
|
|
|
sseService.sendData( dataId, x );
|
|
|
stream2db(x.substring(6), dataId);
|