test: 修复 FitBoundedEmitterTest.testFlatMap 间歇性失败

修复了 testFlatMap 测试中的间歇性失败问题。该测试在完整构建时偶尔失败，报告期望 3 个数据但只收集到 2 个。

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

解决方案：
- 使用 Collections.synchronizedList() 包装 ArrayList，确保线程安全
- 避免并发访问导致的数据丢失问题

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

Author: CodeCasterX

framework/waterflow/java/waterflow-eco/waterflow-bridge-fit-reactor/src/test/java/modelengine/fit/waterflow/bridge/fitflow/FitBoundedEmitterTest.java

@@ -22,6 +22,7 @@
 import org.junit.jupiter.api.Test;
 
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -80,7 +81,7 @@ void baseTest() {
     @Test
     void testFlatMap() {
         AtomicBoolean end = new AtomicBoolean(false);
-        List<Integer> result = new ArrayList<>();
+        List<Integer> result = Collections.synchronizedList(new ArrayList<>());
         FlowSession session = new FlowSession();
         Window window = session.begin();
         ProcessFlow<Integer> flow = Flows.<Integer>create().flatMap(input -> {