Class ClientPushH2StreamHandler
java.lang.Object
org.apache.hc.core5.http2.impl.nio.ClientPushH2StreamHandler
- All Implemented Interfaces:
ResourceHolder
,H2StreamHandler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final BasicHttpConnectionMetrics
private final HttpCoreContext
private final AtomicBoolean
private AsyncPushConsumer
private final AtomicBoolean
private final HttpProcessor
private final H2StreamChannel
private final HandlerFactory
<AsyncPushConsumer> private HttpRequest
private MessageState
private MessageState
-
Constructor Summary
ConstructorsConstructorDescriptionClientPushH2StreamHandler
(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpCoreContext context) -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
isDone()
boolean
void
void
toString()
void
-
Field Details
-
internalOutputChannel
-
httpProcessor
-
connMetrics
-
pushHandlerFactory
-
context
-
failed
-
done
-
request
-
exchangeHandler
-
requestState
-
responseState
-
-
Constructor Details
-
ClientPushH2StreamHandler
ClientPushH2StreamHandler(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpCoreContext context)
-
-
Method Details
-
getPushHandlerFactory
- Specified by:
getPushHandlerFactory
in interfaceH2StreamHandler
-
isOutputReady
public boolean isOutputReady()- Specified by:
isOutputReady
in interfaceH2StreamHandler
-
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
-
isDone
public boolean isDone() -
failed
- Specified by:
failed
in interfaceH2StreamHandler
-
handle
- Specified by:
handle
in interfaceH2StreamHandler
- Throws:
HttpException
-
releaseResources
public void releaseResources()- Specified by:
releaseResources
in interfaceResourceHolder
-
toString
-