Class ServerH2StreamMultiplexer
java.lang.Object
org.apache.hc.core5.http2.impl.nio.AbstractH2StreamMultiplexer
org.apache.hc.core5.http2.impl.nio.ServerH2StreamMultiplexer
- All Implemented Interfaces:
Closeable
,AutoCloseable
,HttpConnection
,SocketModalCloseable
,ModalCloseable
,Identifiable
I/O event handler for events fired by
ProtocolIOSession
that implements
server side HTTP/2 messaging protocol with full support for
multiplexed message transmission.- Since:
- 5.0
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hc.core5.http2.impl.nio.AbstractH2StreamMultiplexer
AbstractH2StreamMultiplexer.ConnectionHandshake, AbstractH2StreamMultiplexer.H2Stream, AbstractH2StreamMultiplexer.SettingsHandshake
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionServerH2StreamMultiplexer
(ProtocolIOSession ioSession, HttpProcessor httpProcessor, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, CharCodingConfig charCodingConfig, H2Config h2Config) ServerH2StreamMultiplexer
(ProtocolIOSession ioSession, FrameFactory frameFactory, HttpProcessor httpProcessor, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, CharCodingConfig charCodingConfig, H2Config h2Config, H2StreamListener streamListener) -
Method Summary
Modifier and TypeMethodDescription(package private) void
(package private) void
(package private) void
(package private) H2StreamHandler
createLocallyInitiatedStream
(ExecutableCommand command, H2StreamChannel channel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics) (package private) H2StreamHandler
createRemotelyInitiatedStream
(H2StreamChannel channel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, HandlerFactory<AsyncPushConsumer> pushHandlerFactory) decodeHeaders
(ByteBuffer payload) toString()
Methods inherited from class org.apache.hc.core5.http2.impl.nio.AbstractH2StreamMultiplexer
appendState, close, close, getEndpointDetails, getId, getLocalAddress, getProtocolVersion, getRemoteAddress, getSocketTimeout, getSSLSession, isOpen, onConnect, onDisconnect, onException, onInput, onOutput, onTimeout, setSocketTimeout
-
Field Details
-
exchangeHandlerFactory
-
-
Constructor Details
-
ServerH2StreamMultiplexer
public ServerH2StreamMultiplexer(ProtocolIOSession ioSession, FrameFactory frameFactory, HttpProcessor httpProcessor, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, CharCodingConfig charCodingConfig, H2Config h2Config, H2StreamListener streamListener) -
ServerH2StreamMultiplexer
public ServerH2StreamMultiplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, CharCodingConfig charCodingConfig, H2Config h2Config)
-
-
Method Details
-
acceptHeaderFrame
- Specified by:
acceptHeaderFrame
in classAbstractH2StreamMultiplexer
- Throws:
H2ConnectionException
-
acceptPushRequest
- Specified by:
acceptPushRequest
in classAbstractH2StreamMultiplexer
- Throws:
H2ConnectionException
-
acceptPushFrame
- Specified by:
acceptPushFrame
in classAbstractH2StreamMultiplexer
- Throws:
H2ConnectionException
-
createRemotelyInitiatedStream
H2StreamHandler createRemotelyInitiatedStream(H2StreamChannel channel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, HandlerFactory<AsyncPushConsumer> pushHandlerFactory) throws IOException - Specified by:
createRemotelyInitiatedStream
in classAbstractH2StreamMultiplexer
- Throws:
IOException
-
createLocallyInitiatedStream
H2StreamHandler createLocallyInitiatedStream(ExecutableCommand command, H2StreamChannel channel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics) throws IOException - Specified by:
createLocallyInitiatedStream
in classAbstractH2StreamMultiplexer
- Throws:
IOException
-
decodeHeaders
- Overrides:
decodeHeaders
in classAbstractH2StreamMultiplexer
- Throws:
HttpException
-
toString
-