public class RxNettyHttpHandlerAdapter extends Object implements io.reactivex.netty.protocol.http.server.RequestHandler<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf>
HttpHandler to the RxNetty RequestHandler.| Constructor and Description |
|---|
RxNettyHttpHandlerAdapter(HttpHandler httpHandler) |
| Modifier and Type | Method and Description |
|---|---|
rx.Observable<Void> |
handle(io.reactivex.netty.protocol.http.server.HttpServerRequest<io.netty.buffer.ByteBuf> request,
io.reactivex.netty.protocol.http.server.HttpServerResponse<io.netty.buffer.ByteBuf> response) |
public RxNettyHttpHandlerAdapter(HttpHandler httpHandler)
public rx.Observable<Void> handle(io.reactivex.netty.protocol.http.server.HttpServerRequest<io.netty.buffer.ByteBuf> request, io.reactivex.netty.protocol.http.server.HttpServerResponse<io.netty.buffer.ByteBuf> response)
handle in interface io.reactivex.netty.protocol.http.server.RequestHandler<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf>