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)

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

Specified by:

processRequest in interface ReactiveRequestProcessor

Throws:

HttpException

IOException