enhancement: #1947 implement chain of responsibilities with java stream (#2123)

chain-of-responsibility/README.md

@@ -118,18 +118,24 @@ The Orc King gives the orders and forms the chain.
 
 ```java
 public class OrcKing {
-  RequestHandler chain;
+
+  private List<RequestHandler> handlers;
 
   public OrcKing() {
     buildChain();
   }
 
   private void buildChain() {
-    chain = new OrcCommander(new OrcOfficer(new OrcSoldier(null)));
+    handlers = Arrays.asList(new OrcCommander(), new OrcOfficer(), new OrcSoldier());
   }
 
   public void makeRequest(Request req) {
-    chain.handleRequest(req);
+    handlers
+        .stream()
+        .sorted(Comparator.comparing(RequestHandler::getPriority))
+        .filter(handler -> handler.canHandleRequest(req))
+        .findFirst()
+        .ifPresent(handler -> handler.handle(req));
   }
 }
 ```

chain-of-responsibility/etc/chain-of-responsibility.urm.puml

@@ -5,25 +5,34 @@ package com.iluwatar.chain {
     + main(args : String[]) {static}
   }
   class OrcCommander {
-    + OrcCommander(handler : RequestHandler)
+    - LOGGER : Logger {static}
-    + handleRequest(req : Request)
+    + OrcCommander()
-    + toString() : String
+    + canHandleRequest(req : Request) : boolean
+    + getPriority() : int
+    + handle(req : Request)
+    + name() : String
   }
   class OrcKing {
-    - chain : RequestHandler
+    - handlers : List<RequestHandler>
     + OrcKing()
     - buildChain()
     + makeRequest(req : Request)
   }
   class OrcOfficer {
-    + OrcOfficer(handler : RequestHandler)
+    - LOGGER : Logger {static}
-    + handleRequest(req : Request)
+    + OrcOfficer()
-    + toString() : String
+    + canHandleRequest(req : Request) : boolean
+    + getPriority() : int
+    + handle(req : Request)
+    + name() : String
   }
   class OrcSoldier {
-    + OrcSoldier(handler : RequestHandler)
+    - LOGGER : Logger {static}
-    + handleRequest(req : Request)
+    + OrcSoldier()
-    + toString() : String
+    + canHandleRequest(req : Request) : boolean
+    + getPriority() : int
+    + handle(req : Request)
+    + name() : String
   }
   class Request {
     - handled : boolean
@@ -36,13 +45,11 @@ package com.iluwatar.chain {
     + markHandled()
     + toString() : String
   }
-  abstract class RequestHandler {
+  interface RequestHandler {
-    - LOGGER : Logger {static}
+    + canHandleRequest(Request) : boolean {abstract}
-    - next : RequestHandler
+    + getPriority() : int {abstract}
-    + RequestHandler(next : RequestHandler)
+    + handle(Request) {abstract}
-    + handleRequest(req : Request)
+    + name() : String {abstract}
-    # printHandling(req : Request)
-    + toString() : String {abstract}
   }
   enum RequestType {
     + COLLECT_TAX {static}
@@ -52,10 +59,9 @@ package com.iluwatar.chain {
     + values() : RequestType[] {static}
   }
 }
-OrcKing -->  "-chain" RequestHandler
+OrcKing -->  "-handlers" RequestHandler
-RequestHandler -->  "-next" RequestHandler
 Request -->  "-requestType" RequestType
-OrcCommander --|> RequestHandler 
+OrcCommander ..|> RequestHandler 
-OrcOfficer --|> RequestHandler 
+OrcOfficer ..|> RequestHandler 
-OrcSoldier --|> RequestHandler 
+OrcSoldier ..|> RequestHandler 
 @enduml

chain-of-responsibility/src/main/java/com/iluwatar/chain/OrcCommander.java

@@ -24,27 +24,31 @@
  */
 package com.iluwatar.chain;
 
+import lombok.extern.slf4j.Slf4j;
+
 /**
  * OrcCommander.
  */
-public class OrcCommander extends RequestHandler {
+@Slf4j
-
+public class OrcCommander implements RequestHandler {
-  public OrcCommander(RequestHandler handler) {
+  @Override
-    super(handler);
+  public boolean canHandleRequest(Request req) {
+    return req.getRequestType() == RequestType.DEFEND_CASTLE;
   }
 
   @Override
-  public void handleRequest(Request req) {
+  public int getPriority() {
-    if (RequestType.DEFEND_CASTLE == req.getRequestType()) {
+    return 2;
-      printHandling(req);
-      req.markHandled();
-    } else {
-      super.handleRequest(req);
-    }
   }
 
   @Override
-  public String toString() {
+  public void handle(Request req) {
+    req.markHandled();
+    LOGGER.info("{} handling request \"{}\"", name(), req);
+  }
+
+  @Override
+  public String name() {
     return "Orc commander";
   }
 }

chain-of-responsibility/src/main/java/com/iluwatar/chain/OrcKing.java

@@ -24,23 +24,34 @@
  */
 package com.iluwatar.chain;
 
+import java.util.Arrays;
+import java.util.Comparator;
+import java.util.List;
+
 /**
  * OrcKing makes requests that are handled by the chain.
  */
 public class OrcKing {
 
-  private RequestHandler chain;
+  private List<RequestHandler> handlers;
 
   public OrcKing() {
     buildChain();
   }
 
   private void buildChain() {
-    chain = new OrcCommander(new OrcOfficer(new OrcSoldier(null)));
+    handlers = Arrays.asList(new OrcCommander(), new OrcOfficer(), new OrcSoldier());
   }
 
+  /**
+   * Handle request by the chain.
+   */
   public void makeRequest(Request req) {
-    chain.handleRequest(req);
+    handlers
+        .stream()
+        .sorted(Comparator.comparing(RequestHandler::getPriority))
+        .filter(handler -> handler.canHandleRequest(req))
+        .findFirst()
+        .ifPresent(handler -> handler.handle(req));
   }
-
 }

chain-of-responsibility/src/main/java/com/iluwatar/chain/OrcOfficer.java

@@ -24,28 +24,32 @@
  */
 package com.iluwatar.chain;
 
+import lombok.extern.slf4j.Slf4j;
+
 /**
  * OrcOfficer.
  */
-public class OrcOfficer extends RequestHandler {
+@Slf4j
-
+public class OrcOfficer implements RequestHandler {
-  public OrcOfficer(RequestHandler handler) {
+  @Override
-    super(handler);
+  public boolean canHandleRequest(Request req) {
+    return req.getRequestType() == RequestType.TORTURE_PRISONER;
   }
 
   @Override
-  public void handleRequest(Request req) {
+  public int getPriority() {
-    if (RequestType.TORTURE_PRISONER == req.getRequestType()) {
+    return 3;
-      printHandling(req);
-      req.markHandled();
-    } else {
-      super.handleRequest(req);
-    }
   }
 
   @Override
-  public String toString() {
+  public void handle(Request req) {
+    req.markHandled();
+    LOGGER.info("{} handling request \"{}\"", name(), req);
+  }
+
+  @Override
+  public String name() {
     return "Orc officer";
   }
-
 }
+

chain-of-responsibility/src/main/java/com/iluwatar/chain/OrcSoldier.java

@@ -24,27 +24,31 @@
  */
 package com.iluwatar.chain;
 
+import lombok.extern.slf4j.Slf4j;
+
 /**
  * OrcSoldier.
  */
-public class OrcSoldier extends RequestHandler {
+@Slf4j
-
+public class OrcSoldier implements RequestHandler {
-  public OrcSoldier(RequestHandler handler) {
+  @Override
-    super(handler);
+  public boolean canHandleRequest(Request req) {
+    return req.getRequestType() == RequestType.COLLECT_TAX;
   }
 
   @Override
-  public void handleRequest(Request req) {
+  public int getPriority() {
-    if (RequestType.COLLECT_TAX == req.getRequestType()) {
+    return 1;
-      printHandling(req);
-      req.markHandled();
-    } else {
-      super.handleRequest(req);
-    }
   }
 
   @Override
-  public String toString() {
+  public void handle(Request req) {
+    req.markHandled();
+    LOGGER.info("{} handling request \"{}\"", name(), req);
+  }
+
+  @Override
+  public String name() {
     return "Orc soldier";
   }
 }

chain-of-responsibility/src/main/java/com/iluwatar/chain/RequestHandler.java

@@ -24,31 +24,16 @@
  */
 package com.iluwatar.chain;
 
-import lombok.AllArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-
 /**
  * RequestHandler.
  */
-@Slf4j
+public interface RequestHandler {
-@AllArgsConstructor
-public abstract class RequestHandler {
 
-  private final RequestHandler next;
+  boolean canHandleRequest(Request req);
 
-  /**
+  int getPriority();
-   * Request handler.
-   */
-  public void handleRequest(Request req) {
-    if (next != null) {
-      next.handleRequest(req);
-    }
-  }
 
-  protected void printHandling(Request req) {
+  void handle(Request req);
-    LOGGER.info("{} handling request \"{}\"", this, req);
-  }
 
-  @Override
+  String name();
-  public abstract String toString();
 }