public final class ReactiveEchoProcessor extends Object implements ReactiveRequestProcessor
| Constructor and Description | 
|---|
| ReactiveEchoProcessor() | 
| Modifier and Type | Method and Description | 
|---|---|
| void | processRequest(HttpRequest request,
              EntityDetails entityDetails,
              ResponseChannel responseChannel,
              HttpContext context,
              org.reactivestreams.Publisher<ByteBuffer> requestBody,
              Callback<org.reactivestreams.Publisher<ByteBuffer>> responseBodyFuture)Processes the actual HTTP request. | 
public void processRequest(HttpRequest request, EntityDetails entityDetails, ResponseChannel responseChannel, HttpContext context, org.reactivestreams.Publisher<ByteBuffer> requestBody, Callback<org.reactivestreams.Publisher<ByteBuffer>> responseBodyFuture) throws HttpException, IOException
ReactiveRequestProcessorprocessRequest in interface ReactiveRequestProcessorrequest - the actual request.entityDetails - the request entity details or null if the request
                      does not enclose an entity.responseChannel - the response channel.context - the actual execution context.requestBody - a reactive stream representing the request body.responseBodyFuture - a callback to invoke with the response body, if any.HttpExceptionIOExceptionCopyright © 2005–2022 The Apache Software Foundation. All rights reserved.