Package org.apache.hc.client5.testing.async

Class AsyncRandomHandler

java.lang.Object

org.apache.hc.client5.testing.async.AsyncRandomHandler

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 AsyncRandomHandler
extends java.lang.Object
implements org.apache.hc.core5.http.nio.AsyncServerExchangeHandler

A handler that generates random data.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncRandomHandler.RandomBinAsyncEntityProducer	An entity that generates random data.

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.concurrent.atomic.AtomicReference<org.apache.hc.core5.http.nio.AsyncEntityProducer>	entityProducerRef

Constructor Summary

Constructors

Constructor	Description
AsyncRandomHandler()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

entityProducerRef

private final java.util.concurrent.atomic.AtomicReference<org.apache.hc.core5.http.nio.AsyncEntityProducer> entityProducerRef

Constructor Detail

AsyncRandomHandler

public AsyncRandomHandler()

Method Detail

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface org.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 interface org.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 interface org.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 interface org.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 interface org.apache.hc.core5.http.nio.AsyncDataConsumer

Throws:

org.apache.hc.core5.http.HttpException

java.io.IOException

available

public int available()

Specified by:

available in interface org.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 interface org.apache.hc.core5.http.nio.AsyncDataProducer

Throws:

java.io.IOException

failed

public void failed(java.lang.Exception cause)

Specified by:

failed in interface org.apache.hc.core5.http.nio.AsyncDataExchangeHandler