Class ClientHttp1StreamHandler
- java.lang.Object
-
- org.apache.hc.core5.http.impl.nio.ClientHttp1StreamHandler
-
- All Implemented Interfaces:
ResourceHolder
class ClientHttp1StreamHandler extends java.lang.Object implements ResourceHolder
-
-
Field Summary
Fields Modifier and Type Field Description private HttpRequest
committedRequest
private ConnectionReuseStrategy
connectionReuseStrategy
private HttpCoreContext
context
private java.util.concurrent.atomic.AtomicBoolean
done
private AsyncClientExchangeHandler
exchangeHandler
private Http1Config
http1Config
private HttpProcessor
httpProcessor
private DataStreamChannel
internalDataChannel
private boolean
keepAlive
private Http1StreamChannel<HttpRequest>
outputChannel
private java.util.concurrent.atomic.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
appendState(java.lang.StringBuilder buf)
private void
commitRequest(HttpRequest request, EntityDetails entityDetails)
(package private) void
consumeData(java.nio.ByteBuffer src)
(package private) void
consumeHeader(HttpResponse response, EntityDetails entityDetails)
(package private) void
dataEnd(java.util.List<? extends Header> trailers)
(package private) void
failed(java.lang.Exception cause)
(package private) java.lang.String
getRequestMethod()
(package private) boolean
handleTimeout()
(package private) boolean
isCompleted()
(package private) boolean
isOutputReady()
(package private) boolean
isResponseFinal()
(package private) void
produceOutput()
void
releaseResources()
java.lang.String
toString()
(package private) void
updateCapacity(CapacityChannel capacityChannel)
-
-
-
Field Detail
-
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 java.util.concurrent.atomic.AtomicBoolean requestCommitted
-
done
private final java.util.concurrent.atomic.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 Detail
-
ClientHttp1StreamHandler
ClientHttp1StreamHandler(Http1StreamChannel<HttpRequest> outputChannel, HttpProcessor httpProcessor, Http1Config http1Config, ConnectionReuseStrategy connectionReuseStrategy, AsyncClientExchangeHandler exchangeHandler, HttpCoreContext context)
-
-
Method Detail
-
isResponseFinal
boolean isResponseFinal()
-
isCompleted
boolean isCompleted()
-
getRequestMethod
java.lang.String getRequestMethod()
-
isOutputReady
boolean isOutputReady()
-
commitRequest
private void commitRequest(HttpRequest request, EntityDetails entityDetails) throws java.io.IOException, HttpException
- Throws:
java.io.IOException
HttpException
-
produceOutput
void produceOutput() throws HttpException, java.io.IOException
- Throws:
HttpException
java.io.IOException
-
consumeHeader
void consumeHeader(HttpResponse response, EntityDetails entityDetails) throws HttpException, java.io.IOException
- Throws:
HttpException
java.io.IOException
-
consumeData
void consumeData(java.nio.ByteBuffer src) throws HttpException, java.io.IOException
- Throws:
HttpException
java.io.IOException
-
updateCapacity
void updateCapacity(CapacityChannel capacityChannel) throws java.io.IOException
- Throws:
java.io.IOException
-
dataEnd
void dataEnd(java.util.List<? extends Header> trailers) throws HttpException, java.io.IOException
- Throws:
HttpException
java.io.IOException
-
handleTimeout
boolean handleTimeout()
-
failed
void failed(java.lang.Exception cause)
-
releaseResources
public void releaseResources()
- Specified by:
releaseResources
in interfaceResourceHolder
-
appendState
void appendState(java.lang.StringBuilder buf)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-