[fel] clean code

Author: loveTsong

framework/fel/java/fel-flow/src/main/java/modelengine/fel/engine/activities/AiWhenHappen.java

@@ -30,6 +30,15 @@ public class AiWhenHappen<O, D, I, RF extends Flow<D>, F extends AiFlow<D, RF>>
 
     private final F flow;
 
+    /**
+     * Creates a new AI flow matching generator that handles conditional branching.
+     * This constructor initializes a stateful processor for when/then style pattern matching
+     * within AI workflows.
+     *
+     * @param matchHappen The core matching generator that evaluates conditions
+     * @param flow The parent AI flow
+     * @throws NullPointerException If either parameter is null
+     */
     public AiWhenHappen(WhenHappen<O, D, I, RF> matchHappen, F flow) {
         this.matchHappen = Validation.notNull(matchHappen, "WhenHappen cannot be null.");
         this.flow = Validation.notNull(flow, "Flow cannot be null.");

framework/fel/java/fel-flow/src/test/java/modelengine/fel/engine/AiFlowCaseTest.java

@@ -21,6 +21,7 @@
 import modelengine.fitframework.flowable.Choir;
 
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Nested;
 import org.junit.jupiter.api.Test;
 
@@ -35,6 +36,7 @@
  */
 public class AiFlowCaseTest {
     private static final int SPEED = 1;
+
     @Nested
     class DesensitizeCase {
         private final ChatFlowModel model = new ChatFlowModel((prompt, chatOption) -> Choir.create(emitter -> {
@@ -69,6 +71,7 @@ class DesensitizeCase {
                 .close();
 
         @Test
+        @DisplayName("DesensitizeCase")
         void run() {
             AtomicInteger counter = new AtomicInteger(0);
             long startTime = System.currentTimeMillis();
@@ -148,6 +151,7 @@ class BackPressureCase {
                 .close();
 
         @Test
+        @DisplayName("BackPressureCase")
         void run() {
             AtomicInteger counter = new AtomicInteger(0);
             long startTime = System.currentTimeMillis();
@@ -199,6 +203,7 @@ class ConcurrencyCase {
                 .close();
 
         @Test
+        @DisplayName("ConcurrencyCase")
         void run() {
             AtomicInteger counter = new AtomicInteger(0);
             long startTime = System.currentTimeMillis();

framework/waterflow/java/waterflow-core/src/main/java/modelengine/fit/waterflow/domain/stream/nodes/To.java

@@ -161,6 +161,7 @@ public class To<I, O> extends IdGenerator implements Subscriber<I, O> {
     private Operators.Produce<FlowContext<I>, O> produce;
 
     private volatile int maxConcurrency = MAX_CONCURRENCY;
+
     /**
      * 当前并发度，已经提交的批次
      */