refactor thingy

Author: Rene Sprietsma

README.md

@@ -8,7 +8,7 @@ Inspired by ['Build You Own Web Framework In Go'](https://www.nicolasmerouze.com
 
 [![Build Status](https://travis-ci.org/spriet2000/vertx-handlers-http.svg?branch=master)](https://travis-ci.org/spriet2000/vertx-handlers-http)
 
-## Example
+## Setup server request handlers
 
 ```java 
 
@@ -30,3 +30,24 @@ Inspired by ['Build You Own Web Framework In Go'](https://www.nicolasmerouze.com
 
 ```
 
+## Implement server request handlers
+
+```java 
+
+    public class ExampleHandler implements BiFunction<BiConsumer<StringBuilder, Throwable>,
+            BiConsumer<StringBuilder, Void>, BiConsumer<StringBuilder, Void>> {
+
+        @Override
+        public BiConsumer<StringBuilder, Void> apply(BiConsumer<StringBuilder, Throwable> fail,
+                                                     BiConsumer<StringBuilder, Void> next) {
+            return next;
+        }
+    }
+
+```
+
+
+### Remarks
+
+* When var, or something like, enters the JAVA language, defining handlers is quite less verbose. http://openjdk.java.net/jeps/286
+* Implementing handler still is quite verbose. 

src/main/java/com/github/spriet2000/vertx/handlers/core/BiHandlers.java

@@ -0,0 +1,21 @@
+package com.github.spriet2000.vertx.handlers.core;
+
+import com.github.spriet2000.vertx.handlers.core.impl.BiHandlersImpl;
+
+import java.util.List;
+import java.util.function.BiConsumer;
+import java.util.function.BiFunction;
+
+
+public interface BiHandlers<E, A> {
+
+    BiConsumer<E, A> apply(BiConsumer<E, Throwable> exceptionHandler, BiConsumer<E, A> successHandler);
+
+    BiHandlersImpl<E, A> andThen(BiConsumer<E, A>... consumers);
+
+    BiHandlersImpl<E, A> andThen(BiFunction<BiConsumer<E, Throwable>, BiConsumer<E, A>, BiConsumer<E, A>>... handlers);
+
+    BiHandlersImpl<E, A> andThen(BiHandlersImpl<E, A>... handlers);
+
+    List<BiFunction<BiConsumer<E, Throwable>, BiConsumer<E, A>, BiConsumer<E, A>>> handlers();
+}

src/main/java/com/github/spriet2000/vertx/handlers/core/http/ServerRequestHandlers.java

@@ -0,0 +1,63 @@
+package com.github.spriet2000.vertx.handlers.core.impl;
+
+import com.github.spriet2000.vertx.handlers.core.BiHandlers;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.function.BiConsumer;
+import java.util.function.BiFunction;
+import java.util.stream.Collectors;
+
+public final class BiHandlersImpl<E, A> implements BiHandlers<E, A> {
+
+    private List<BiFunction<BiConsumer<E, Throwable>, BiConsumer<E, A>, BiConsumer<E, A>>> handlers;
+
+    public BiHandlersImpl() {
+    }
+
+    @Override
+    public BiConsumer<E, A> apply(BiConsumer<E, Throwable> exceptionHandler, BiConsumer<E, A> successHandler) {
+        BiConsumer<E, A> last = successHandler;
+        for (int i = handlers.size() - 1; i >= 0; i--) {
+            final BiConsumer<E, A> previous = last;
+            last = handlers.get(i).apply(
+                    exceptionHandler,
+                    previous);
+        }
+        return last;
+    }
+
+    @Override
+    @SafeVarargs
+    public final BiHandlersImpl<E, A> andThen(BiConsumer<E, A>... consumers) {
+        for (BiConsumer<E, A> consumer : consumers) {
+            handlers().add((f, n) -> consumer);
+        }
+        return this;
+    }
+
+    @Override
+    @SafeVarargs
+    public final BiHandlersImpl<E, A> andThen(BiFunction<BiConsumer<E, Throwable>, BiConsumer<E, A>, BiConsumer<E, A>>... handlers) {
+        Collections.addAll(handlers(), handlers);
+        return this;
+    }
+
+    @Override
+    @SafeVarargs
+    public final BiHandlersImpl<E, A> andThen(BiHandlersImpl<E, A>... handlers) {
+        for (BiHandlersImpl<E, A> handler : handlers) {
+            handlers().addAll(handler.handlers().stream().collect(Collectors.toList()));
+        }
+        return this;
+    }
+
+    @Override
+    public List<BiFunction<BiConsumer<E, Throwable>, BiConsumer<E, A>, BiConsumer<E, A>>> handlers() {
+        if (handlers == null) {
+            handlers = new ArrayList<>();
+        }
+        return handlers;
+    }
+}

src/main/java/com/github/spriet2000/vertx/handlers/core/impl/BiHandlersImpl.java

@@ -0,0 +1,8 @@
+package com.github.spriet2000.vertx.handlers.http.handlers.bodyParser;
+
+
+public interface Body<T> {
+    void body(T body);
+
+    T body();
+}

src/main/java/com/github/spriet2000/vertx/handlers/extensions/bodyParser/Body.java

@@ -1,4 +1,4 @@
-package com.github.spriet2000.vertx.handlers.extensions.bodyParser;
+package com.github.spriet2000.vertx.handlers.http.handlers.bodyParser;
 
 
 public final class BodyParseException extends Exception {

src/main/java/com/github/spriet2000/vertx/handlers/extensions/timeout/TimeoutException.java

@@ -1,8 +1,8 @@
-package com.github.spriet2000.vertx.handlers.extensions.bodyParser.impl;
+package com.github.spriet2000.vertx.handlers.http.handlers.bodyParser.impl;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import com.github.spriet2000.vertx.handlers.extensions.bodyParser.Body;
-import com.github.spriet2000.vertx.handlers.extensions.bodyParser.BodyParseException;
+import com.github.spriet2000.vertx.handlers.http.handlers.bodyParser.Body;
+import com.github.spriet2000.vertx.handlers.http.handlers.bodyParser.BodyParseException;
 import io.netty.handler.codec.http.HttpHeaders;
 import io.vertx.core.buffer.Buffer;
 import io.vertx.core.http.HttpMethod;

src/main/java/com/github/spriet2000/vertx/handlers/http/handlers/bodyParser/Body.java

@@ -1,9 +1,9 @@
-package com.github.spriet2000.vertx.handlers.extensions.bodyParser.impl;
+package com.github.spriet2000.vertx.handlers.http.handlers.bodyParser.impl;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.dataformat.xml.XmlMapper;
-import com.github.spriet2000.vertx.handlers.extensions.bodyParser.Body;
-import com.github.spriet2000.vertx.handlers.extensions.bodyParser.BodyParseException;
+import com.github.spriet2000.vertx.handlers.http.handlers.bodyParser.Body;
+import com.github.spriet2000.vertx.handlers.http.handlers.bodyParser.BodyParseException;
 import io.netty.handler.codec.http.HttpHeaders;
 import io.vertx.core.buffer.Buffer;
 import io.vertx.core.http.HttpMethod;