Merge branch '3.6.x'

Author: CodeCasterX

framework/fel/python/requirements.txt

@@ -1,4 +1,4 @@
 llama-index==0.12.46
-langchain-core==0.3.68
+langchain-core==0.3.81
 langchain_community==0.3.27
-langchain-openai==0.3.28
+langchain-openai==0.3.28

framework/fit/java/fit-builtin/services/fit-http-classic/definition/src/test/java/modelengine/fit/http/client/support/TextStreamChoirTest.java

@@ -27,6 +27,8 @@
 
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
 import java.util.Optional;
 
 /**
@@ -38,9 +40,9 @@
 @DisplayName("测试 TextStreamChoir")
 class TextStreamChoirTest {
     private static class TestSubscriber<T> extends EmptySubscriber<T> {
-        private final ArrayList<String> records;
+        private final List<String> records;
 
-        public TestSubscriber(ArrayList<String> records) {
+        public TestSubscriber(List<String> records) {
             this.records = records;
         }
 
@@ -95,7 +97,7 @@ void shouldReturnDataAndCompleteWhenDataEmittedBeforeSubscribeCompleted() {
             stringEmitter.complete();
         });
         TextStreamChoir<String> textStreamChoir = createStringTextStreamChoir(convertedChoir, 200);
-        ArrayList<String> records = new ArrayList<>();
+        List<String> records = Collections.synchronizedList(new ArrayList<>());
         Subscriber<String> mySubscriber = new TestSubscriber<>(records);
         textStreamChoir.subscribe(mySubscriber);
         records.add("after subscribe");
@@ -112,7 +114,7 @@ void shouldReturnDataAndCompleteWhenDataEmittedAfterSubscribeCompleted() {
         Emitter<String> emitter = new DefaultEmitter<>();
         Choir<String> convertedChoir = Choir.fromEmitter(emitter);
         TextStreamChoir<String> textStreamChoir = createStringTextStreamChoir(convertedChoir, 200);
-        ArrayList<String> records = new ArrayList<>();
+        List<String> records = Collections.synchronizedList(new ArrayList<>());
         Subscriber<String> mySubscriber = new TestSubscriber<>(records);
         textStreamChoir.subscribe(mySubscriber);
         records.add("after subscribe");
@@ -140,7 +142,7 @@ void shouldReturnDataAndCompleteWhenDataEmittedAfterSubscribeCompletedWithNewThr
             }).start();
         });
         TextStreamChoir<String> textStreamChoir = createStringTextStreamChoir(convertedChoir, 200);
-        ArrayList<String> records = new ArrayList<>();
+        List<String> records = Collections.synchronizedList(new ArrayList<>());
         Subscriber<String> mySubscriber = new TestSubscriber<>(records);
         textStreamChoir.subscribe(mySubscriber);
         records.add("after subscribe");
@@ -164,7 +166,7 @@ void shouldReturnDataAndFailWhenHttpExchangeFailAndChoirCreateByCreate() {
             stringEmitter.complete();
         });
         TextStreamChoir<String> textStreamChoir = createStringTextStreamChoir(convertedChoir, 500);
-        ArrayList<String> records = new ArrayList<>();
+        List<String> records = Collections.synchronizedList(new ArrayList<>());
         Subscriber<String> mySubscriber = new TestSubscriber<>(records);
         textStreamChoir.subscribe(mySubscriber);
         records.add("after subscribe");
@@ -177,7 +179,7 @@ void shouldReturnDataAndFailWhenHttpExchangeFailAndChoirCreateByFromEmitter() {
         Emitter<String> emitter = new DefaultEmitter<>();
         Choir<String> convertedChoir = Choir.fromEmitter(emitter);
         TextStreamChoir<String> textStreamChoir = createStringTextStreamChoir(convertedChoir, 400);
-        ArrayList<String> records = new ArrayList<>();
+        List<String> records = Collections.synchronizedList(new ArrayList<>());
         Subscriber<String> mySubscriber = new TestSubscriber<>(records);
         textStreamChoir.subscribe(mySubscriber);
         records.add("after subscribe");
@@ -194,7 +196,7 @@ void shouldReturnDataAndFailWhenDataEmittedBeforeSubscribeCompleted() {
             stringEmitter.fail(new RuntimeException(""));
         });
         TextStreamChoir<String> textStreamChoir = createStringTextStreamChoir(convertedChoir, 200);
-        ArrayList<String> records = new ArrayList<>();
+        List<String> records = Collections.synchronizedList(new ArrayList<>());
         Subscriber<String> mySubscriber = new TestSubscriber<>(records);
         textStreamChoir.subscribe(mySubscriber);
         records.add("after subscribe");
@@ -211,7 +213,7 @@ void shouldReturnDataAndFailWhenDataEmittedAfterSubscribeCompleted() {
         Emitter<String> emitter = new DefaultEmitter<>();
         Choir<String> convertedChoir = Choir.fromEmitter(emitter);
         TextStreamChoir<String> textStreamChoir = createStringTextStreamChoir(convertedChoir, 200);
-        ArrayList<String> records = new ArrayList<>();
+        List<String> records = Collections.synchronizedList(new ArrayList<>());
         Subscriber<String> mySubscriber = new TestSubscriber<>(records);
         textStreamChoir.subscribe(mySubscriber);
         records.add("after subscribe");
@@ -239,7 +241,7 @@ void shouldReturnDataAndFailWhenDataEmittedAfterSubscribeCompletedWithNewThread(
             }).start();
         });
         TextStreamChoir<String> textStreamChoir = createStringTextStreamChoir(convertedChoir, 200);
-        ArrayList<String> records = new ArrayList<>();
+        List<String> records = Collections.synchronizedList(new ArrayList<>());
         Subscriber<String> mySubscriber = new TestSubscriber<>(records);
         textStreamChoir.subscribe(mySubscriber);
         records.add("after subscribe");