test: 修复 TextStreamChoirTest 多线程测试的间歇性失败

修复了 TextStreamChoirTest 中多线程测试的间歇性失败问题。该测试在 GitHub Actions 构建时失败，报告列表内容相同但对象引用不同的断言错误。

根本原因：
- 测试中使用的 ArrayList 不是线程安全的
- 在响应式流处理中，可能存在多个线程同时访问 records 列表的情况
- 竞态条件导致并发访问时的数据不一致

解决方案：
- 使用 Collections.synchronizedList() 包装 ArrayList，确保线程安全
- 修改 TestSubscriber 类中的类型声明从 ArrayList 改为 List
- 与之前修复 FitBoundedEmitterTest 的方法保持一致

受影响的测试方法：
- shouldReturnDataAndCompleteWhenDataEmittedBeforeSubscribeCompleted
- shouldReturnDataAndCompleteWhenDataEmittedAfterSubscribeCompleted
- shouldReturnDataAndCompleteWhenDataEmittedAfterSubscribeCompletedWithNewThread (已失败)
- shouldReturnDataAndFailWhenHttpExchangeFailAndChoirCreateByCreate
- shouldReturnDataAndFailWhenHttpExchangeFailAndChoirCreateByFromEmitter
- shouldReturnDataAndFailWhenDataEmittedBeforeSubscribeCompleted
- shouldReturnDataAndFailWhenDataEmittedAfterSubscribeCompleted
- shouldReturnDataAndFailWhenDataEmittedAfterSubscribeCompletedWithNewThread

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>

Author: CodeCasterX

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");