Merge pull request #204 from gorzell/HandlerInterface

Add a generic Handler interface
ReactiveX · Aug 13, 2014 · cafeb0d · cafeb0d
2 parents 7a8ace3 + 628c6e1
commit cafeb0d
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/rx-netty/src/main/java/io/reactivex/netty/channel/Handler.java b/rx-netty/src/main/java/io/reactivex/netty/channel/Handler.java
@@ -0,0 +1,10 @@
+package io.reactivex.netty.channel;
+
+
+import rx.Observable;
+
+public interface Handler<IN, OUT> {
+
+    Observable<Void> handle(IN input, OUT output);
+
+}
diff --git a/rx-netty/src/main/java/io/reactivex/netty/protocol/http/server/RequestHandler.java b/rx-netty/src/main/java/io/reactivex/netty/protocol/http/server/RequestHandler.java
@@ -15,12 +15,13 @@
  */
 package io.reactivex.netty.protocol.http.server;
 
+import io.reactivex.netty.channel.Handler;
 import rx.Observable;
 
 /**
  * @author Nitesh Kant
  */
-public interface RequestHandler<I, O> {
+public interface RequestHandler<I, O> extends Handler<HttpServerRequest<I>, HttpServerResponse<O>> {
 
     Observable<Void> handle(HttpServerRequest<I> request, HttpServerResponse<O> response);