provider add delay for test

Author: chengyouling

demo/demo-spring-boot-transport/demo-spring-boot-springmvc-server/src/main/java/org/apache/servicecomb/springboot/springmvc/server/ReactiveStreamController.java

@@ -16,6 +16,8 @@
  */
 package org.apache.servicecomb.springboot.springmvc.server;
 
+import java.util.Arrays;
+import java.util.List;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 
@@ -34,24 +36,28 @@
 public class ReactiveStreamController {
   @GetMapping("/sseString")
   public Publisher<String> sseString() {
-    return Flowable.fromArray("a", "b", "c");
+    List<String> data = Arrays.asList("a", "b", "c");
+    return Flowable.intervalRange(0, 3, 5000, 1, TimeUnit.SECONDS)
+        .map(item -> data.get(item.intValue()));
   }
 
   @GetMapping("/sseStringWithParam")
   public Publisher<String> sseStringWithParam(@RequestParam(name = "name") String name) {
-    return Flowable.fromArray("a", "b", "c", name);
+    List<String> data = Arrays.asList("a", "b", "c", name);
+    return Flowable.intervalRange(0, 4, 5000, 1, TimeUnit.SECONDS)
+        .map(item -> data.get(item.intValue()));
   };
 
   @GetMapping("/sseModel")
   public Publisher<Model> sseModel() {
-    return Flowable.intervalRange(0, 5, 0, 1, TimeUnit.SECONDS)
+    return Flowable.intervalRange(0, 5, 5000, 1, TimeUnit.SECONDS)
         .map(item -> new Model("jack", item.intValue()));
   }
 
   @GetMapping("/sseResponseEntity")
   public Publisher<SseEventResponseEntity<Model>> sseResponseEntity() {
     AtomicInteger index = new AtomicInteger(0);
-    return Flowable.intervalRange(0, 3, 0, 1, TimeUnit.SECONDS)
+    return Flowable.intervalRange(0, 3, 5000, 1, TimeUnit.SECONDS)
         .map(item -> new SseEventResponseEntity<Model>()
             .event("test" + index)
             .eventId(index.getAndIncrement())