Class AsyncEchoHandler
- java.lang.Object
-
- org.apache.hc.client5.testing.async.AsyncEchoHandler
-
- All Implemented Interfaces:
org.apache.hc.core5.http.nio.AsyncDataConsumer
,org.apache.hc.core5.http.nio.AsyncDataExchangeHandler
,org.apache.hc.core5.http.nio.AsyncDataProducer
,org.apache.hc.core5.http.nio.AsyncServerExchangeHandler
,org.apache.hc.core5.http.nio.ResourceHolder
public class AsyncEchoHandler extends java.lang.Object implements org.apache.hc.core5.http.nio.AsyncServerExchangeHandler
A handler that echos the incoming request entity.
-
-
Field Summary
Fields Modifier and Type Field Description private org.apache.hc.core5.http.nio.entity.BasicAsyncEntityConsumer
entityConsumer
private java.util.concurrent.atomic.AtomicReference<org.apache.hc.core5.http.nio.AsyncEntityProducer>
entityProducerRef
-
Constructor Summary
Constructors Constructor Description AsyncEchoHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
available()
void
consume(java.nio.ByteBuffer src)
void
failed(java.lang.Exception cause)
void
handleRequest(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.EntityDetails entityDetails, org.apache.hc.core5.http.nio.ResponseChannel responseChannel, org.apache.hc.core5.http.protocol.HttpContext context)
void
produce(org.apache.hc.core5.http.nio.DataStreamChannel channel)
void
releaseResources()
void
streamEnd(java.util.List<? extends org.apache.hc.core5.http.Header> trailers)
void
updateCapacity(org.apache.hc.core5.http.nio.CapacityChannel capacityChannel)
-
-
-
Method Detail
-
releaseResources
public void releaseResources()
- Specified by:
releaseResources
in interfaceorg.apache.hc.core5.http.nio.ResourceHolder
-
handleRequest
public void handleRequest(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.EntityDetails entityDetails, org.apache.hc.core5.http.nio.ResponseChannel responseChannel, org.apache.hc.core5.http.protocol.HttpContext context) throws org.apache.hc.core5.http.HttpException, java.io.IOException
- Specified by:
handleRequest
in interfaceorg.apache.hc.core5.http.nio.AsyncServerExchangeHandler
- Throws:
org.apache.hc.core5.http.HttpException
java.io.IOException
-
updateCapacity
public void updateCapacity(org.apache.hc.core5.http.nio.CapacityChannel capacityChannel) throws java.io.IOException
- Specified by:
updateCapacity
in interfaceorg.apache.hc.core5.http.nio.AsyncDataConsumer
- Throws:
java.io.IOException
-
consume
public void consume(java.nio.ByteBuffer src) throws java.io.IOException
- Specified by:
consume
in interfaceorg.apache.hc.core5.http.nio.AsyncDataConsumer
- Throws:
java.io.IOException
-
streamEnd
public void streamEnd(java.util.List<? extends org.apache.hc.core5.http.Header> trailers) throws org.apache.hc.core5.http.HttpException, java.io.IOException
- Specified by:
streamEnd
in interfaceorg.apache.hc.core5.http.nio.AsyncDataConsumer
- Throws:
org.apache.hc.core5.http.HttpException
java.io.IOException
-
available
public int available()
- Specified by:
available
in interfaceorg.apache.hc.core5.http.nio.AsyncDataProducer
-
produce
public void produce(org.apache.hc.core5.http.nio.DataStreamChannel channel) throws java.io.IOException
- Specified by:
produce
in interfaceorg.apache.hc.core5.http.nio.AsyncDataProducer
- Throws:
java.io.IOException
-
failed
public void failed(java.lang.Exception cause)
- Specified by:
failed
in interfaceorg.apache.hc.core5.http.nio.AsyncDataExchangeHandler
-
-