fixes

Author: spriet2000

README.md

@@ -54,7 +54,7 @@ public class EndHandler<A> implements
 
 <dependency>
     <groupId>com.github.spriet2000</groupId>
-    <artifactId>vertx-handlers</artifactId>
+    <artifactId>handlers</artifactId>
     <version>0.1.0-SNAPSHOT</version>
 </dependency>
 

pom.xml

@@ -31,7 +31,7 @@
 
         <dependency>
             <groupId>com.github.spriet2000</groupId>
-            <artifactId>vertx-handlers</artifactId>
+            <artifactId>handlers</artifactId>
             <version>0.1.0-SNAPSHOT</version>
         </dependency>
 

src/main/java/com/github/spriet2000/vertx/handlers/http/server/ext/impl/EndHandler.java

@@ -6,11 +6,11 @@
 import java.util.function.BiFunction;
 import java.util.function.Consumer;
 
-public class EndHandler<A> implements BiFunction<Consumer<Throwable>, Consumer<Object>,
+public class EndHandler<A> implements BiFunction<Consumer<Throwable>, Consumer<A>,
         BiConsumer<HttpServerRequest, A>> {
 
     @Override
-    public BiConsumer<HttpServerRequest, A> apply(Consumer<Throwable> fail, Consumer<Object> next) {
+    public BiConsumer<HttpServerRequest, A> apply(Consumer<Throwable> fail, Consumer<A> next) {
         return (req, arg) -> {
             if (req != null && !req.isEnded()) {
                 req.response().end();

src/main/java/com/github/spriet2000/vertx/handlers/http/server/ext/impl/ExceptionHandler.java

@@ -6,11 +6,11 @@
 import java.util.function.BiFunction;
 import java.util.function.Consumer;
 
-public class ExceptionHandler<A> implements BiFunction<Consumer<Throwable>, Consumer<Object>,
+public class ExceptionHandler<A> implements BiFunction<Consumer<Throwable>, Consumer<A>,
         BiConsumer<HttpServerRequest, A>> {
 
     @Override
-    public BiConsumer<HttpServerRequest, A> apply(Consumer<Throwable> fail, Consumer<Object> next) {
+    public BiConsumer<HttpServerRequest, A> apply(Consumer<Throwable> fail, Consumer<A> next) {
         return (req, arg) -> {
             try {
                 next.accept(arg);

src/main/java/com/github/spriet2000/vertx/handlers/http/server/ext/impl/ResponseTimeHandler.java

@@ -6,11 +6,11 @@
 import java.util.function.BiFunction;
 import java.util.function.Consumer;
 
-public class ResponseTimeHandler<A> implements BiFunction<Consumer<Throwable>, Consumer<Object>,
+public class ResponseTimeHandler<A> implements BiFunction<Consumer<Throwable>, Consumer<A>,
         BiConsumer<HttpServerRequest, A>> {
 
     @Override
-    public BiConsumer<HttpServerRequest, A> apply(Consumer<Throwable> fail, Consumer<Object> next) {
+    public BiConsumer<HttpServerRequest, A> apply(Consumer<Throwable> fail, Consumer<A> next) {
         return (req, arg) -> {
             long start = System.nanoTime();
             req.response().headersEndHandler(e -> {

src/main/java/com/github/spriet2000/vertx/handlers/http/server/ext/impl/TimeOutHandler.java

@@ -7,7 +7,7 @@
 import java.util.function.BiFunction;
 import java.util.function.Consumer;
 
-public class TimeOutHandler<A> implements BiFunction<Consumer<Throwable>, Consumer<Object>,
+public class TimeOutHandler<A> implements BiFunction<Consumer<Throwable>, Consumer<A>,
         BiConsumer<HttpServerRequest, A>> {
 
     private final Vertx vertx;
@@ -24,7 +24,7 @@ public TimeOutHandler(Vertx vertx, long time) {
     }
 
     @Override
-    public BiConsumer<HttpServerRequest, A> apply(Consumer<Throwable> fail, Consumer<Object> next) {
+    public BiConsumer<HttpServerRequest, A> apply(Consumer<Throwable> fail, Consumer<A> next) {
         return (req, arg) -> {
             long id = vertx.setTimer(time, c -> fail.accept(new RuntimeException()));
             req.response().bodyEndHandler(e -> vertx.cancelTimer(id));

src/test/java/com/github/spriet2000/vertx/handlers/http/tests/Example.java

@@ -33,7 +33,7 @@ public void setup() {
     @Test
     public void example1() {
 
-        Handlers<HttpServerRequest, Void> handlers = compose(
+        Handlers<HttpServerRequest, Object> handlers = compose(
                 new ExceptionHandler(),
                 new ResponseTimeHandler(),
                 new TimeOutHandler(vertx),