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 delegate) |
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 delegate)
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>