Class ClientH2StreamHandler
java.lang.Object
org.apache.hc.core5.http2.impl.nio.ClientH2StreamHandler
- All Implemented Interfaces:
ResourceHolder
,H2StreamHandler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final BasicHttpConnectionMetrics
private final HttpCoreContext
private final DataStreamChannel
private final AtomicBoolean
private final AsyncClientExchangeHandler
private final AtomicBoolean
private final HttpProcessor
private final H2StreamChannel
private final HandlerFactory
<AsyncPushConsumer> private final AtomicBoolean
private MessageState
private MessageState
-
Constructor Summary
ConstructorsConstructorDescriptionClientH2StreamHandler
(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpCoreContext context) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
commitRequest
(HttpRequest request, EntityDetails entityDetails) void
consumeData
(ByteBuffer src, boolean endStream) void
consumeHeader
(List<Header> headers, boolean endStream) void
consumePromise
(List<Header> headers) void
void
handle
(HttpException ex, boolean endStream) boolean
void
void
toString()
void
-
Field Details
-
outputChannel
-
dataChannel
-
httpProcessor
-
connMetrics
-
exchangeHandler
-
pushHandlerFactory
-
context
-
requestCommitted
-
failed
-
done
-
requestState
-
responseState
-
-
Constructor Details
-
ClientH2StreamHandler
ClientH2StreamHandler(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpCoreContext context)
-
-
Method Details
-
getPushHandlerFactory
- Specified by:
getPushHandlerFactory
in interfaceH2StreamHandler
-
isOutputReady
public boolean isOutputReady()- Specified by:
isOutputReady
in interfaceH2StreamHandler
-
commitRequest
private void commitRequest(HttpRequest request, EntityDetails entityDetails) throws HttpException, IOException - Throws:
HttpException
IOException
-
produceOutput
- Specified by:
produceOutput
in interfaceH2StreamHandler
- Throws:
HttpException
IOException
-
consumePromise
- Specified by:
consumePromise
in interfaceH2StreamHandler
- Throws:
HttpException
IOException
-
consumeHeader
public void consumeHeader(List<Header> headers, boolean endStream) throws HttpException, IOException - Specified by:
consumeHeader
in interfaceH2StreamHandler
- Throws:
HttpException
IOException
-
updateInputCapacity
- Specified by:
updateInputCapacity
in interfaceH2StreamHandler
- Throws:
IOException
-
consumeData
- Specified by:
consumeData
in interfaceH2StreamHandler
- Throws:
HttpException
IOException
-
handle
- Specified by:
handle
in interfaceH2StreamHandler
- Throws:
HttpException
IOException
-
failed
- Specified by:
failed
in interfaceH2StreamHandler
-
releaseResources
public void releaseResources()- Specified by:
releaseResources
in interfaceResourceHolder
-
toString
-