Class ClientHttp1StreamHandler
java.lang.Object
org.apache.hc.core5.http.impl.nio.ClientHttp1StreamHandler
- All Implemented Interfaces:
ResourceHolder
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate HttpRequest
private final ConnectionReuseStrategy
private final HttpCoreContext
private final AtomicBoolean
private final AsyncClientExchangeHandler
private final Http1Config
private final HttpProcessor
private final DataStreamChannel
private boolean
private final Http1StreamChannel
<HttpRequest> private final AtomicBoolean
private MessageState
private MessageState
private Timeout
-
Constructor Summary
ConstructorsConstructorDescriptionClientHttp1StreamHandler
(Http1StreamChannel<HttpRequest> outputChannel, HttpProcessor httpProcessor, Http1Config http1Config, ConnectionReuseStrategy connectionReuseStrategy, AsyncClientExchangeHandler exchangeHandler, HttpCoreContext context) -
Method Summary
Modifier and TypeMethodDescription(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
(package private) void
(package private) String
(package private) boolean
(package private) boolean
(package private) boolean
(package private) boolean
(package private) void
void
toString()
(package private) void
updateCapacity
(CapacityChannel capacityChannel)
-
Field Details
-
outputChannel
-
internalDataChannel
-
httpProcessor
-
http1Config
-
connectionReuseStrategy
-
exchangeHandler
-
context
-
requestCommitted
-
done
-
keepAlive
private volatile boolean keepAlive -
timeout
-
committedRequest
-
requestState
-
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
- Throws:
HttpException
IOException
-
consumeHeader
void consumeHeader(HttpResponse response, EntityDetails entityDetails) throws HttpException, IOException - Throws:
HttpException
IOException
-
consumeData
- Throws:
HttpException
IOException
-
updateCapacity
- Throws:
IOException
-
dataEnd
- Throws:
HttpException
IOException
-
handleTimeout
boolean handleTimeout() -
failed
-
releaseResources
public void releaseResources()- Specified by:
releaseResources
in interfaceResourceHolder
-
appendState
-
toString
-