handler implementation started

Author: ZNevzz

src/main/java/spring/znevzz/reactive/controller/CacheController.java

@@ -1,25 +1,29 @@
 package spring.znevzz.reactive.controller;
 
+import lombok.AllArgsConstructor;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 import reactor.core.publisher.Flux;
-import spring.znevzz.reactive.bean.ICacheRequest;
 import spring.znevzz.reactive.bean.ICacheResponse;
 import spring.znevzz.reactive.bean.SimpleCacheRequest;
+import spring.znevzz.reactive.handler.IRequestHandler;
 
+@AllArgsConstructor
 @RestController
 public class CacheController {
 
+    private final IRequestHandler handler;
+
     @GetMapping("/")
     public String welcome() {
         return "welcome";
     }
 
     @PostMapping("/cache")
     public Flux<ICacheResponse> fromCache(@RequestBody SimpleCacheRequest request) {
-        return Flux.empty();
+        return handler.getFromCache(request);
     }
 
 }

src/main/java/spring/znevzz/reactive/handler/CacheRequestHandler.java

@@ -2,6 +2,7 @@
 
 import org.springframework.stereotype.Component;
 import org.springframework.web.reactive.function.server.ServerRequest;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import spring.znevzz.reactive.bean.ICacheRequest;
 import spring.znevzz.reactive.bean.ICacheResponse;
@@ -18,4 +19,9 @@ public Mono handle(ServerRequest serverRequest) {
     public Mono<ICacheResponse> get(ICacheRequest iCacheRequest) {
         return Mono.empty();
     }
+
+    @Override
+    public Flux<ICacheResponse> getFromCache(ICacheRequest request) {
+        return Flux.empty();
+    }
 }

src/main/java/spring/znevzz/reactive/handler/IRequestHandler.java

@@ -14,6 +14,8 @@ public interface  IRequestHandler<T,R> extends HandlerFunction {
 
     Mono<R> get(T t);
 
+    Flux<R> getFromCache(T t);
+
     default <T extends ServerResponse> Mono<T> welcome(ServerRequest serverRequest) {
         Mono welcomeMessage = Mono.empty();
         Mono<String> responseMessage = Mono.just("welcome");