Class ServerH2StreamHandler
java.lang.Object
org.apache.hc.core5.http2.impl.nio.ServerH2StreamHandler
- All Implemented Interfaces:
ResourceHolder
,H2StreamHandler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final BasicHttpConnectionMetrics
private final HttpCoreContext
private final DataStreamChannel
private final AtomicBoolean
private AsyncServerExchangeHandler
private final HandlerFactory
<AsyncServerExchangeHandler> private final AtomicBoolean
private final HttpProcessor
private final H2StreamChannel
private HttpRequest
private MessageState
private final ResponseChannel
private final AtomicBoolean
private MessageState
-
Constructor Summary
ConstructorsConstructorDescriptionServerH2StreamHandler
(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, 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> headers, boolean endStream) void
consumePromise
(List<Header> headers) void
void
handle
(HttpException ex, boolean endStream) boolean
void
void
toString()
void
-
Field Details
-
outputChannel
-
dataChannel
-
responseChannel
-
httpProcessor
-
connMetrics
-
exchangeHandlerFactory
-
context
-
responseCommitted
-
failed
-
done
-
exchangeHandler
-
receivedRequest
-
requestState
-
responseState
-
-
Constructor Details
-
ServerH2StreamHandler
ServerH2StreamHandler(H2StreamChannel outputChannel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, HttpCoreContext context)
-
-
Method Details
-
getPushHandlerFactory
- Specified by:
getPushHandlerFactory
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
-
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
-
isOutputReady
public boolean isOutputReady()- Specified by:
isOutputReady
in interfaceH2StreamHandler
-
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
-