public class ReactiveRandomProcessor extends Object implements ReactiveRequestProcessor
| Constructor and Description |
|---|
ReactiveRandomProcessor() |
| 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>> responseBodyCallback)
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>> responseBodyCallback) 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.responseBodyCallback - a callback to invoke with the response body, if any.HttpExceptionIOExceptionCopyright © 2005–2021 The Apache Software Foundation. All rights reserved.