1

秦芳睿

9 天以前 e70a362606b78a822e93d5117a9013e8f9086faf

 JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/javaai/llm/qwen/SMTLLMConnectQwen.java

@@ -120,6 +120,7 @@
          //return result.getOutput().getChoices().get(0).getMessage().getContent();

          

          tranReq.sendChunkedBlock("begin_stream", "");

          tranReq. sendChunkedBlock("send_stream", "开始分析：\n");

          String[] fullContent = new String[] {""};

          Flowable<GenerationResult> result = _gen.streamCall(param);

          result.blockingForEach(message -> {

@@ -130,7 +131,7 @@
                return;

             

             fullContent[0] = content;

             tranReq.sendChunkedBlock("send_stream", content.substring(size));

             tranReq.sendChunkedStreamBlock(content.substring(size));

          });

          tranReq.sendChunkedBlock("end_stream", "");

          return fullContent[0];