Class ReactiveRandomProcessor
java.lang.Object
org.apache.hc.core5.testing.reactive.ReactiveRandomProcessor
- All Implemented Interfaces:
ReactiveRequestProcessor
-
Constructor Summary
Constructors -
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.
-
Constructor Details
-
ReactiveRandomProcessor
public ReactiveRandomProcessor()
-
-
Method Details
-
processRequest
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 Description copied from interface:ReactiveRequestProcessor
Processes the actual HTTP request. The handler can choose to send response messages immediately inside the call or asynchronously at some later point.- Specified by:
processRequest
in interfaceReactiveRequestProcessor
- 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
-