refactor: 增加自定义setting设置支持

jetlinks · Oct 8, 2024 · c297a9b · c297a9b
1 parent 85b2dfa
commit c297a9b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/test/java/org/jetlinks/reactor/ql/ReactorQLTest.java b/src/test/java/org/jetlinks/reactor/ql/ReactorQLTest.java
@@ -1020,6 +1020,8 @@ void testCustomFunction() {
         ReactorQL.builder()
                  .sql("select upper('name') name from t1")
                  .feature(new SingleParameterFunctionMapFeature("upper", v -> String.valueOf(v).toUpperCase()))
+                 .setting("concurrency", 10)
+                 .settings(Collections.singletonMap("concurrency",0))
                  .build()
                  .start(Flux.just(1))
                  .as(StepVerifier::create)
@@ -2069,7 +2071,7 @@ void testErrorMatch() {
                 .builder()
                 .sql("select 1 from dual where left>right")
                 .build()
-                .start(Flux.range(0,100_0000).map(ignore->data))
+                .start(Flux.range(0, 100_0000).map(ignore -> data))
                 .doOnNext(System.out::println)
                 .as(StepVerifier::create)
                 .expectNextCount(0)