org.springframework.http.server.reactive

Class RxNettyHttpHandlerAdapter

java.lang.Object

org.springframework.http.server.reactive.HttpHandlerAdapterSupport

org.springframework.http.server.reactive.RxNettyHttpHandlerAdapter

All Implemented Interfaces:

io.reactivex.netty.protocol.http.server.RequestHandler<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf>

public class RxNettyHttpHandlerAdapter
extends HttpHandlerAdapterSupport
implements io.reactivex.netty.protocol.http.server.RequestHandler<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf>

Adapt HttpHandler to the RxNetty RequestHandler.

Since:

5.0

Author:

Rossen Stoyanchev

Field Summary

Fields inherited from class org.springframework.http.server.reactive.HttpHandlerAdapterSupport

logger

Constructor Summary

Constructors

Constructor and Description
RxNettyHttpHandlerAdapter(HttpHandler httpHandler)
RxNettyHttpHandlerAdapter(Map<String,HttpHandler> handlerMap)

Method Summary

Modifier and Type	Method and Description
rx.Observable<Void>	handle(io.reactivex.netty.protocol.http.server.HttpServerRequest<io.netty.buffer.ByteBuf> nativeRequest, io.reactivex.netty.protocol.http.server.HttpServerResponse<io.netty.buffer.ByteBuf> nativeResponse)

Methods inherited from class org.springframework.http.server.reactive.HttpHandlerAdapterSupport

getHttpHandler

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RxNettyHttpHandlerAdapter

public RxNettyHttpHandlerAdapter(HttpHandler httpHandler)

RxNettyHttpHandlerAdapter

public RxNettyHttpHandlerAdapter(Map<String,HttpHandler> handlerMap)

Method Detail

handle

public rx.Observable<Void> handle(io.reactivex.netty.protocol.http.server.HttpServerRequest<io.netty.buffer.ByteBuf> nativeRequest,
                                  io.reactivex.netty.protocol.http.server.HttpServerResponse<io.netty.buffer.ByteBuf> nativeResponse)

Specified by:

handle in interface io.reactivex.netty.protocol.http.server.RequestHandler<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf>