This is an automated email from the ASF dual-hosted git repository. albumenj pushed a commit to branch 3.3 in repository https://gitbox.apache.org/repos/asf/dubbo.git
commit 191697a3403ea345403bf3566fea2e8890ba9aea Author: Albumen Kevin <jhq0...@gmail.com> AuthorDate: Mon May 13 14:50:24 2024 +0800 Fix merge style --- .../main/java/org/apache/dubbo/reactive/calls/ReactorServerCalls.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/dubbo-plugin/dubbo-reactive/src/main/java/org/apache/dubbo/reactive/calls/ReactorServerCalls.java b/dubbo-plugin/dubbo-reactive/src/main/java/org/apache/dubbo/reactive/calls/ReactorServerCalls.java index ea96e071e8..3e1de817c6 100644 --- a/dubbo-plugin/dubbo-reactive/src/main/java/org/apache/dubbo/reactive/calls/ReactorServerCalls.java +++ b/dubbo-plugin/dubbo-reactive/src/main/java/org/apache/dubbo/reactive/calls/ReactorServerCalls.java @@ -22,7 +22,6 @@ import org.apache.dubbo.reactive.ServerTripleReactorSubscriber; import org.apache.dubbo.rpc.StatusRpcException; import org.apache.dubbo.rpc.TriRpcStatus; import org.apache.dubbo.rpc.protocol.tri.observer.CallStreamObserver; -import org.apache.dubbo.rpc.protocol.tri.observer.ServerCallToObserverAdapter; import java.util.List; import java.util.concurrent.CompletableFuture; @@ -70,8 +69,7 @@ public final class ReactorServerCalls { public static <T, R> CompletableFuture<List<R>> oneToMany( T request, StreamObserver<R> responseObserver, Function<Mono<T>, Flux<R>> func) { try { - CallStreamObserver<R> callStreamObserver = - (CallStreamObserver<R>) responseObserver; + CallStreamObserver<R> callStreamObserver = (CallStreamObserver<R>) responseObserver; Flux<R> response = func.apply(Mono.just(request)); ServerTripleReactorSubscriber<R> reactorSubscriber = new ServerTripleReactorSubscriber<>(callStreamObserver);