Package org.apache.hc.core5.reactive
Interface ReactiveRequestProcessor
- All Known Implementing Classes:
ReactiveEchoProcessor
,ReactiveRandomProcessor
public interface ReactiveRequestProcessor
- Since:
- 5.0
-
Method Summary
Modifier and TypeMethodDescriptionvoid
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.
-
Method Details
-
processRequest
void processRequest(HttpRequest request, EntityDetails entityDetails, ResponseChannel responseChannel, HttpContext context, org.reactivestreams.Publisher<ByteBuffer> requestBody, Callback<org.reactivestreams.Publisher<ByteBuffer>> responseBodyCallback) throws HttpException, IOException Processes the actual HTTP request. The handler can choose to send response messages immediately inside the call or asynchronously at some later point.- Parameters:
request
- the actual request.entityDetails
- the request entity details ornull
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.- Throws:
HttpException
IOException
-