Class ClientH2StreamMultiplexer
- java.lang.Object
-
- org.apache.hc.core5.http2.impl.nio.AbstractH2StreamMultiplexer
-
- org.apache.hc.core5.http2.impl.nio.ClientH2StreamMultiplexer
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,HttpConnection
,SocketModalCloseable
,ModalCloseable
,Identifiable
@Internal public class ClientH2StreamMultiplexer extends AbstractH2StreamMultiplexer
I/O event handler for events fired byProtocolIOSession
that implements client 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 Modifier and Type Field Description private HandlerFactory<AsyncPushConsumer>
pushHandlerFactory
-
Constructor Summary
Constructors Constructor Description ClientH2StreamMultiplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, H2Config h2Config, CharCodingConfig charCodingConfig)
ClientH2StreamMultiplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, H2Config h2Config, CharCodingConfig charCodingConfig)
ClientH2StreamMultiplexer(ProtocolIOSession ioSession, FrameFactory frameFactory, HttpProcessor httpProcessor, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, H2Config h2Config, CharCodingConfig charCodingConfig, H2StreamListener streamListener)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
acceptHeaderFrame()
(package private) void
acceptPushFrame()
(package private) void
acceptPushRequest()
(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)
java.lang.String
toString()
-
Methods inherited from class org.apache.hc.core5.http2.impl.nio.AbstractH2StreamMultiplexer
appendState, close, close, decodeHeaders, getEndpointDetails, getId, getLocalAddress, getProtocolVersion, getRemoteAddress, getSocketTimeout, getSSLSession, isOpen, onConnect, onDisconnect, onException, onInput, onOutput, onTimeout, setSocketTimeout
-
-
-
-
Field Detail
-
pushHandlerFactory
private final HandlerFactory<AsyncPushConsumer> pushHandlerFactory
-
-
Constructor Detail
-
ClientH2StreamMultiplexer
public ClientH2StreamMultiplexer(ProtocolIOSession ioSession, FrameFactory frameFactory, HttpProcessor httpProcessor, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, H2Config h2Config, CharCodingConfig charCodingConfig, H2StreamListener streamListener)
-
ClientH2StreamMultiplexer
public ClientH2StreamMultiplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, H2Config h2Config, CharCodingConfig charCodingConfig)
-
ClientH2StreamMultiplexer
public ClientH2StreamMultiplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, H2Config h2Config, CharCodingConfig charCodingConfig)
-
-
Method Detail
-
acceptHeaderFrame
void acceptHeaderFrame() throws H2ConnectionException
- Specified by:
acceptHeaderFrame
in classAbstractH2StreamMultiplexer
- Throws:
H2ConnectionException
-
acceptPushFrame
void acceptPushFrame() throws H2ConnectionException
- Specified by:
acceptPushFrame
in classAbstractH2StreamMultiplexer
- Throws:
H2ConnectionException
-
acceptPushRequest
void acceptPushRequest() throws H2ConnectionException
- Specified by:
acceptPushRequest
in classAbstractH2StreamMultiplexer
- Throws:
H2ConnectionException
-
createLocallyInitiatedStream
H2StreamHandler createLocallyInitiatedStream(ExecutableCommand command, H2StreamChannel channel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics) throws java.io.IOException
- Specified by:
createLocallyInitiatedStream
in classAbstractH2StreamMultiplexer
- Throws:
java.io.IOException
-
createRemotelyInitiatedStream
H2StreamHandler createRemotelyInitiatedStream(H2StreamChannel channel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, HandlerFactory<AsyncPushConsumer> pushHandlerFactory) throws java.io.IOException
- Specified by:
createRemotelyInitiatedStream
in classAbstractH2StreamMultiplexer
- Throws:
java.io.IOException
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-