Package org.apache.hc.core5.http2.impl.nio

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 by ProtocolIOSession 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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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 class AbstractH2StreamMultiplexer

Throws:

H2ConnectionException

acceptPushFrame

void acceptPushFrame()
              throws H2ConnectionException

Specified by:

acceptPushFrame in class AbstractH2StreamMultiplexer

Throws:

H2ConnectionException

acceptPushRequest

void acceptPushRequest()
                throws H2ConnectionException

Specified by:

acceptPushRequest in class AbstractH2StreamMultiplexer

Throws:

H2ConnectionException

createLocallyInitiatedStream

H2StreamHandler createLocallyInitiatedStream(ExecutableCommand command,
                                             H2StreamChannel channel,
                                             HttpProcessor httpProcessor,
                                             BasicHttpConnectionMetrics connMetrics)
                                      throws java.io.IOException

Specified by:

createLocallyInitiatedStream in class AbstractH2StreamMultiplexer

Throws:

java.io.IOException

createRemotelyInitiatedStream

H2StreamHandler createRemotelyInitiatedStream(H2StreamChannel channel,
                                              HttpProcessor httpProcessor,
                                              BasicHttpConnectionMetrics connMetrics,
                                              HandlerFactory<AsyncPushConsumer> pushHandlerFactory)
                                       throws java.io.IOException

Specified by:

createRemotelyInitiatedStream in class AbstractH2StreamMultiplexer

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object