(dubbo) 02/04: Fix merge style

[al...@apache.org]

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 <jh...@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);