Class ServerPushH2StreamHandler
java.lang.Object
org.apache.hc.core5.http2.impl.nio.ServerPushH2StreamHandler
- All Implemented Interfaces:
ResourceHolder
,H2StreamHandler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final BasicHttpConnectionMetrics
private final HttpCoreContext
private final DataStreamChannel
private final AtomicBoolean
private final AtomicBoolean
private final HttpProcessor
private final H2StreamChannel
private final AsyncPushProducer
private MessageState
private final AtomicBoolean
private MessageState
-
Constructor Summary
ConstructorsConstructorDescriptionServerPushH2StreamHandler
(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, AsyncPushProducer pushProducer, HttpCoreContext context) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
commitInformation
(HttpResponse response) private void
commitPromise
(HttpRequest promise, AsyncPushProducer pushProducer) private void
commitResponse
(HttpResponse response, EntityDetails responseEntityDetails) void
consumeData
(ByteBuffer src, boolean endStream) void
consumeHeader
(List<Header> requestHeaders, boolean requestEndStream) void
consumePromise
(List<Header> headers) void
void
handle
(HttpException ex, boolean endStream) boolean
void
void
toString()
void
-
Field Details
-
outputChannel
-
dataChannel
-
httpProcessor
-
connMetrics
-
pushProducer
-
context
-
responseCommitted
-
failed
-
done
-
requestState
-
responseState
-
-
Constructor Details
-
ServerPushH2StreamHandler
ServerPushH2StreamHandler(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, AsyncPushProducer pushProducer, HttpCoreContext context)
-
-
Method Details
-
getPushHandlerFactory
- Specified by:
getPushHandlerFactory
in interfaceH2StreamHandler
-
consumePromise
- Specified by:
consumePromise
in interfaceH2StreamHandler
- Throws:
HttpException
IOException
-
consumeHeader
public void consumeHeader(List<Header> requestHeaders, boolean requestEndStream) 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
-
isOutputReady
public boolean isOutputReady()- Specified by:
isOutputReady
in interfaceH2StreamHandler
-
commitInformation
- Throws:
IOException
HttpException
-
commitResponse
private void commitResponse(HttpResponse response, EntityDetails responseEntityDetails) throws HttpException, IOException - Throws:
HttpException
IOException
-
commitPromise
private void commitPromise(HttpRequest promise, AsyncPushProducer pushProducer) throws HttpException, IOException - Throws:
HttpException
IOException
-
produceOutput
- Specified by:
produceOutput
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
-