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

@@ -37,27 +37,27 @@ public class ReactiveStreamController {
   @GetMapping("/sseString")
   public Publisher<String> sseString() {
     List<String> data = Arrays.asList("a", "b", "c");
-    return Flowable.intervalRange(0, 3, 5000, 1, TimeUnit.SECONDS)
+    return Flowable.intervalRange(0, 3, 5, 1, TimeUnit.SECONDS)
         .map(item -> data.get(item.intValue()));
   }
 
   @GetMapping("/sseStringWithParam")
   public Publisher<String> sseStringWithParam(@RequestParam(name = "name") String name) {
     List<String> data = Arrays.asList("a", "b", "c", name);
-    return Flowable.intervalRange(0, 4, 5000, 1, TimeUnit.SECONDS)
+    return Flowable.intervalRange(0, 4, 5, 1, TimeUnit.SECONDS)
         .map(item -> data.get(item.intValue()));
   };
 
   @GetMapping("/sseModel")
   public Publisher<Model> sseModel() {
-    return Flowable.intervalRange(0, 5, 5000, 1, TimeUnit.SECONDS)
+    return Flowable.intervalRange(0, 5, 5, 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, 5000, 1, TimeUnit.SECONDS)
+    return Flowable.intervalRange(0, 3, 5, 1, TimeUnit.SECONDS)
         .map(item -> new SseEventResponseEntity<Model>()
             .event("test" + index)
             .eventId(index.getAndIncrement())