add LOGGER for test

Author: chengyouling

common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceEventStreamProcessor.java

@@ -23,13 +23,18 @@
 
 import org.apache.commons.lang3.StringUtils;
 import org.apache.servicecomb.common.rest.codec.RestObjectMapperFactory;
+import org.apache.servicecomb.common.rest.filter.inner.ServerRestArgsFilter;
 import org.apache.servicecomb.swagger.sse.SseEventResponseEntity;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import com.fasterxml.jackson.databind.JavaType;
 
 import jakarta.ws.rs.core.MediaType;
 
 public class ProduceEventStreamProcessor implements ProduceProcessor {
+  private static final Logger LOGGER = LoggerFactory.getLogger(ServerRestArgsFilter.class);
+
   private int writeIndex = 0;
 
   @Override
@@ -54,13 +59,15 @@ public void doEncodeResponse(OutputStream output, Object result) throws Exceptio
       appendEventId(bufferBuilder, writeIndex++);
       appendData(bufferBuilder, result);
     }
+    LOGGER.info("==============provider encoder bufferBuilder==============>" + bufferBuilder);
     bufferBuilder.append("\n");
     output.write(bufferBuilder.toString().getBytes(StandardCharsets.UTF_8));
   }
 
   @Override
   public Object doDecodeResponse(InputStream input, JavaType type) throws Exception {
     String buffer = new String(input.readAllBytes(), StandardCharsets.UTF_8);
+    LOGGER.info("=========doDecodeResponse buffer===================>" + buffer);
     SseEventResponseEntity<?> responseEntity = new SseEventResponseEntity<>();
     boolean isResponseEntity = false;
     for (String line : buffer.split("\n")) {

common/common-rest/src/main/java/org/apache/servicecomb/common/rest/filter/inner/ServerRestArgsFilter.java

@@ -86,11 +86,6 @@ public CompletableFuture<Void> beforeSendResponseAsync(Invocation invocation, Ht
     if (isServerSendEvent(response)) {
       produceProcessor = new ProduceEventStreamProcessor();
       responseEx.setContentType(produceProcessor.getName() + "; charset=utf-8");
-      try {
-        Thread.sleep(10000);
-      } catch (InterruptedException e) {
-        throw new RuntimeException(e);
-      }
       return writeServerSendEvent(invocation, response, produceProcessor, responseEx);
     }
 

demo/demo-spring-boot-transport/demo-spring-boot-springmvc-client/src/main/java/org/apache/servicecomb/springboot/springmvc/client/ReactiveStreamIT.java

@@ -58,8 +58,9 @@ private void testSseStringWithParam(ReactiveStreamClient client) throws Exceptio
   }
 
   private String buildBufferString(Publisher<String> result) throws Exception {
-    StringBuilder buffer = new StringBuilder();
     CountDownLatch countDownLatch = new CountDownLatch(1);
+    countDownLatch.await(20, TimeUnit.SECONDS);
+    StringBuilder buffer = new StringBuilder();
     result.subscribe(new Subscriber<>() {
       Subscription subscription;
 
@@ -93,6 +94,7 @@ public void onComplete() {
   private void testSseModel(ReactiveStreamClient client) throws Exception {
     Publisher<Model> result = client.sseModel();
     CountDownLatch countDownLatch = new CountDownLatch(1);
+    countDownLatch.await(20, TimeUnit.SECONDS);
     StringBuilder buffer = new StringBuilder();
     result.subscribe(new Subscriber<>() {
       Subscription subscription;
@@ -127,6 +129,7 @@ public void onComplete() {
   private void testSseResponseEntity(ReactiveStreamClient client) throws Exception {
     Publisher<SseEventResponseEntity<Model>> result = client.sseResponseEntity();
     CountDownLatch countDownLatch = new CountDownLatch(1);
+    countDownLatch.await(20, TimeUnit.SECONDS);
     StringBuilder buffer = new StringBuilder();
     result.subscribe(new Subscriber<>() {
       Subscription subscription;