Package org.apache.hc.core5.testing.reactive

Class ReactiveEchoProcessor

java.lang.Object

org.apache.hc.core5.testing.reactive.ReactiveEchoProcessor

All Implemented Interfaces:

ReactiveRequestProcessor

public final class ReactiveEchoProcessor
extends Object
implements ReactiveRequestProcessor

Constructor Summary

Constructors

Constructor	Description
ReactiveEchoProcessor()

Method Summary

Modifier and Type	Method	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.

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveEchoProcessor

public ReactiveEchoProcessor()

Method Details

processRequest

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

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 interface ReactiveRequestProcessor

Parameters:

request - 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.

Throws:

HttpException

IOException