Class ClientH2StreamMultiplexer

java.lang.Object

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

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

All Implemented Interfaces:

Closeable, 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 AbstractH2StreamMultiplexer

AbstractH2StreamMultiplexer.ConnectionHandshake, AbstractH2StreamMultiplexer.H2StreamChannelImpl, AbstractH2StreamMultiplexer.SettingsHandshake

Field Summary

Fields

Modifier and Type	Field	Description
private final 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) boolean	allowGracefulAbort(H2Stream stream)
(package private) H2Setting[]	generateSettings(H2Config localConfig)
(package private) H2StreamHandler	incomingPushPromise(H2StreamChannel channel, HandlerFactory<AsyncPushConsumer> pushHandlerFactory)
(package private) H2StreamHandler	incomingRequest(H2StreamChannel channel)
(package private) H2StreamHandler	outgoingPushPromise(H2StreamChannel channel, AsyncPushProducer pushProducer)
(package private) H2StreamHandler	outgoingRequest(H2StreamChannel channel, AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context)
String	toString()
(package private) void	validateSetting(H2Param param, int value)

Methods inherited from class AbstractH2StreamMultiplexer

appendState, close, close, createChannel, createStream, decodeHeaders, getConnMetrics, getEndpointDetails, getHttpProcessor, getId, getLocalAddress, getProtocolVersion, getRemoteAddress, getSocketTimeout, getSSLSession, isOpen, onConnect, onDisconnect, onException, onInput, onOutput, onTimeout, requestSessionOutput, setSocketTimeout, submitCommand

Methods inherited from class Object

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

Field Details

pushHandlerFactory

private final HandlerFactory<AsyncPushConsumer> pushHandlerFactory

Constructor Details

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 Details

validateSetting

void validateSetting(H2Param param,
 int value)
              throws H2ConnectionException

Specified by:

validateSetting in class AbstractH2StreamMultiplexer

Throws:

H2ConnectionException

generateSettings

H2Setting[] generateSettings(H2Config localConfig)

Specified by:

generateSettings in class AbstractH2StreamMultiplexer

acceptHeaderFrame

void acceptHeaderFrame()
                throws H2ConnectionException

Specified by:

acceptHeaderFrame in class AbstractH2StreamMultiplexer

Throws:

H2ConnectionException

acceptPushFrame

void acceptPushFrame()

Specified by:

acceptPushFrame in class AbstractH2StreamMultiplexer

acceptPushRequest

void acceptPushRequest()
                throws H2ConnectionException

Specified by:

acceptPushRequest in class AbstractH2StreamMultiplexer

Throws:

H2ConnectionException

outgoingRequest

H2StreamHandler outgoingRequest(H2StreamChannel channel,
 AsyncClientExchangeHandler exchangeHandler,
 HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
 HttpContext context)

Specified by:

outgoingRequest in class AbstractH2StreamMultiplexer

incomingRequest

H2StreamHandler incomingRequest(H2StreamChannel channel)
                         throws IOException

Specified by:

incomingRequest in class AbstractH2StreamMultiplexer

Throws:

IOException

outgoingPushPromise

H2StreamHandler outgoingPushPromise(H2StreamChannel channel,
 AsyncPushProducer pushProducer)
                             throws IOException

Specified by:

outgoingPushPromise in class AbstractH2StreamMultiplexer

Throws:

IOException

incomingPushPromise

H2StreamHandler incomingPushPromise(H2StreamChannel channel,
 HandlerFactory<AsyncPushConsumer> pushHandlerFactory)

Specified by:

incomingPushPromise in class AbstractH2StreamMultiplexer

allowGracefulAbort

boolean allowGracefulAbort(H2Stream stream)

Specified by:

allowGracefulAbort in class AbstractH2StreamMultiplexer

toString

public String toString()

Overrides:

toString in class Object