Package org.apache.hc.core5.http.impl.nio

Class ClientHttp1StreamHandler

java.lang.Object

org.apache.hc.core5.http.impl.nio.ClientHttp1StreamHandler

All Implemented Interfaces:

ResourceHolder

class ClientHttp1StreamHandler
extends Object
implements ResourceHolder

Field Summary

Fields

Modifier and Type	Field	Description
private HttpRequest	committedRequest
private final ConnectionReuseStrategy	connectionReuseStrategy
private final HttpCoreContext	context
private final AtomicBoolean	done
private final AsyncClientExchangeHandler	exchangeHandler
private final Http1Config	http1Config
private final HttpProcessor	httpProcessor
private final DataStreamChannel	internalDataChannel
private boolean	keepAlive
private final Http1StreamChannel<HttpRequest>	outputChannel
private final AtomicBoolean	requestCommitted
private MessageState	requestState
private MessageState	responseState
private Timeout	timeout

Constructor Summary

Constructors

Constructor	Description
ClientHttp1StreamHandler(Http1StreamChannel<HttpRequest> outputChannel, HttpProcessor httpProcessor, Http1Config http1Config, ConnectionReuseStrategy connectionReuseStrategy, AsyncClientExchangeHandler exchangeHandler, HttpCoreContext context)

Method Summary

Modifier and Type	Method	Description
(package private) void	appendState(StringBuilder buf)
private void	commitRequest(HttpRequest request, EntityDetails entityDetails)
(package private) void	consumeData(ByteBuffer src)
(package private) void	consumeHeader(HttpResponse response, EntityDetails entityDetails)
(package private) void	dataEnd(List<? extends Header> trailers)
(package private) void	failed(Exception cause)
(package private) String	getRequestMethod()
(package private) boolean	handleTimeout()
(package private) boolean	isCompleted()
(package private) boolean	isOutputReady()
(package private) boolean	isResponseFinal()
(package private) void	produceOutput()
void	releaseResources()
String	toString()
(package private) void	updateCapacity(CapacityChannel capacityChannel)

Methods inherited from class java.lang.Object

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

Field Details

outputChannel

private final Http1StreamChannel<HttpRequest> outputChannel

internalDataChannel

private final DataStreamChannel internalDataChannel

httpProcessor

private final HttpProcessor httpProcessor

http1Config

private final Http1Config http1Config

connectionReuseStrategy

private final ConnectionReuseStrategy connectionReuseStrategy

exchangeHandler

private final AsyncClientExchangeHandler exchangeHandler

context

private final HttpCoreContext context

requestCommitted

private final AtomicBoolean requestCommitted

done

private final AtomicBoolean done

keepAlive

private volatile boolean keepAlive

timeout

private volatile Timeout timeout

committedRequest

private volatile HttpRequest committedRequest

requestState

private volatile MessageState requestState

responseState

private volatile MessageState responseState

Constructor Details

ClientHttp1StreamHandler

ClientHttp1StreamHandler(Http1StreamChannel<HttpRequest> outputChannel,
 HttpProcessor httpProcessor,
 Http1Config http1Config,
 ConnectionReuseStrategy connectionReuseStrategy,
 AsyncClientExchangeHandler exchangeHandler,
 HttpCoreContext context)

Method Details

isResponseFinal

boolean isResponseFinal()

isCompleted

boolean isCompleted()

getRequestMethod

String getRequestMethod()

isOutputReady

boolean isOutputReady()

commitRequest

private void commitRequest(HttpRequest request,
 EntityDetails entityDetails)
                    throws IOException,
HttpException

Throws:

IOException

HttpException

produceOutput

void produceOutput()
            throws HttpException,
IOException

Throws:

HttpException

IOException

consumeHeader

void consumeHeader(HttpResponse response,
 EntityDetails entityDetails)
            throws HttpException,
IOException

Throws:

HttpException

IOException

consumeData

void consumeData(ByteBuffer src)
          throws HttpException,
IOException

Throws:

HttpException

IOException

updateCapacity

void updateCapacity(CapacityChannel capacityChannel)
             throws IOException

Throws:

IOException

dataEnd

void dataEnd(List<? extends Header> trailers)
      throws HttpException,
IOException

Throws:

HttpException

IOException

handleTimeout

boolean handleTimeout()

failed

void failed(Exception cause)

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder

appendState

void appendState(StringBuilder buf)

toString

public String toString()

Overrides:

toString in class Object