Top Fields Constructors Methods

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

pack-priv Class ClientHttp1StreamHandler

Class Inheritance

extends Object
implements ResourceHolder

java.lang.Object
org.apache.hc.core5.http.impl.nio.ClientHttp1StreamHandler

All Implemented Interfaces

org.apache.hc.core5.http.nio.ResourceHolder

Imports

java.io.IOException, java.nio.ByteBuffer, java.util.List, java.util.concurrent.atomic.AtomicBoolean, org.apache.hc.core5.http.ConnectionReuseStrategy, .EntityDetails, .Header, .HeaderElements, .HttpException, .HttpHeaders, .HttpRequest, .HttpResponse, .HttpStatus, .HttpVersion, .ProtocolException, .ProtocolVersion, .UnsupportedHttpVersionException, org.apache.hc.core5.http.config.Http1Config, org.apache.hc.core5.http.message.StatusLine, org.apache.hc.core5.http.nio.AsyncClientExchangeHandler, .CapacityChannel, .DataStreamChannel, .ResourceHolder, org.apache.hc.core5.http.protocol.HttpCoreContext, .HttpProcessor, org.apache.hc.core5.util.Timeout

Field Summary

Modifier and Type	Field and Description
private volatile 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 volatile boolean	keepAlive
private final Http1StreamChannel<HttpRequest>	outputChannel
private final AtomicBoolean	requestCommitted
private volatile MessageState	requestState
private volatile MessageState	responseState
private volatile Timeout	timeout

Constructor Summary

Access	Constructor and Description
pack-priv	ClientHttp1StreamHandler(final Http1StreamChannel<HttpRequest> outputChannel, final HttpProcessor httpProcessor, final Http1Config http1Config, final ConnectionReuseStrategy connectionReuseStrategy, final AsyncClientExchangeHandler exchangeHandler, final HttpCoreContext context)

Method Summary

Modifier and Type	Method and Description
pack-priv void	appendState(final StringBuilder buf)
private void	commitRequest(final HttpRequest request, final EntityDetails entityDetails)
pack-priv void	consumeData(final ByteBuffer src)
pack-priv void	consumeHeader(final HttpResponse response, final EntityDetails entityDetails)
pack-priv void	dataEnd(final List<? extends Header> trailers)
pack-priv void	failed(final Exception cause)
pack-priv String	getRequestMethod()
pack-priv boolean	handleTimeout()
pack-priv boolean	isCompleted()
pack-priv boolean	isOutputReady()
pack-priv boolean	isResponseFinal()
pack-priv void	produceOutput()
public void	releaseResources() Implements org.apache.hc.core5.http.nio.ResourceHolder.releaseResources.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
pack-priv void	updateCapacity(final CapacityChannel capacityChannel)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

committedRequest	back to summary
private volatile HttpRequest committedRequest

connectionReuseStrategy	back to summary
private final ConnectionReuseStrategy connectionReuseStrategy

context	back to summary
private final HttpCoreContext context

done	back to summary
private final AtomicBoolean done

exchangeHandler	back to summary
private final AsyncClientExchangeHandler exchangeHandler

http1Config	back to summary
private final Http1Config http1Config

httpProcessor	back to summary
private final HttpProcessor httpProcessor

internalDataChannel	back to summary
private final DataStreamChannel internalDataChannel

keepAlive	back to summary
private volatile boolean keepAlive

outputChannel	back to summary
private final Http1StreamChannel<HttpRequest> outputChannel

requestCommitted	back to summary
private final AtomicBoolean requestCommitted

requestState	back to summary
private volatile MessageState requestState

responseState	back to summary
private volatile MessageState responseState

timeout	back to summary
private volatile Timeout timeout

Constructor Detail

ClientHttp1StreamHandler	back to summary
pack-priv ClientHttp1StreamHandler(final Http1StreamChannel<HttpRequest> outputChannel, final HttpProcessor httpProcessor, final Http1Config http1Config, final ConnectionReuseStrategy connectionReuseStrategy, final AsyncClientExchangeHandler exchangeHandler, final HttpCoreContext context)

Method Detail

appendState	back to summary
pack-priv void appendState(final StringBuilder buf)

commitRequest	back to summary
private void commitRequest(final HttpRequest request, final EntityDetails entityDetails) throws IOException, HttpException

consumeData	back to summary
pack-priv void consumeData(final ByteBuffer src) throws HttpException, IOException

consumeHeader	back to summary
pack-priv void consumeHeader(final HttpResponse response, final EntityDetails entityDetails) throws HttpException, IOException

dataEnd	back to summary
pack-priv void dataEnd(final List<? extends Header> trailers) throws HttpException, IOException

failed	back to summary
pack-priv void failed(final Exception cause)

getRequestMethod	back to summary
pack-priv String getRequestMethod()

handleTimeout	back to summary
pack-priv boolean handleTimeout()

isCompleted	back to summary
pack-priv boolean isCompleted()

isOutputReady	back to summary
pack-priv boolean isOutputReady()

isResponseFinal	back to summary
pack-priv boolean isResponseFinal()

produceOutput	back to summary
pack-priv void produceOutput() throws HttpException, IOException

releaseResources

back to summary

public void releaseResources()

Implements org.apache.hc.core5.http.nio.ResourceHolder.releaseResources.

Annotations

@Override

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

updateCapacity	back to summary
pack-priv void updateCapacity(final CapacityChannel capacityChannel) throws IOException