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

Class ServerH2StreamMultiplexer

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, HttpConnection, SocketModalCloseable, ModalCloseable, Identifiable

@Internal
public class ServerH2StreamMultiplexer
extends Object

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

Constructor Summary

Constructors

Constructor	Description
ServerH2StreamMultiplexer(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 Type	Method	Description
void	close()
void	close(CloseMode closeMode)
EndpointDetails	getEndpointDetails()
String	getId()
SocketAddress	getLocalAddress()
ProtocolVersion	getProtocolVersion()
SocketAddress	getRemoteAddress()
Timeout	getSocketTimeout()
SSLSession	getSSLSession()
boolean	isOpen()
final void	onConnect()
final void	onDisconnect()
final void	onException(Exception cause)
final void	onInput(ByteBuffer src)
final void	onOutput()
final void	onTimeout(Timeout timeout)
void	setSocketTimeout(Timeout timeout)
String	toString()

Methods inherited from class java.lang.Object

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

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

toString

public String toString()

Overrides:

toString in class Object

getId

public String getId()

Specified by:

getId in interface Identifiable

onConnect

public final void onConnect()
                     throws HttpException,
IOException

Throws:

HttpException

IOException

onInput

public final void onInput(ByteBuffer src)
                   throws HttpException,
IOException

Throws:

HttpException

IOException

onOutput

public final void onOutput()
                    throws HttpException,
IOException

Throws:

HttpException

IOException

onTimeout

public final void onTimeout(Timeout timeout)
                     throws HttpException,
IOException

Throws:

HttpException

IOException

onDisconnect

public final void onDisconnect()

onException

public final void onException(Exception cause)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface HttpConnection

Throws:

IOException

close

public void close(CloseMode closeMode)

Specified by:

close in interface ModalCloseable

isOpen

public boolean isOpen()

Specified by:

isOpen in interface HttpConnection

setSocketTimeout

public void setSocketTimeout(Timeout timeout)

Specified by:

setSocketTimeout in interface SocketModalCloseable

getSSLSession

public SSLSession getSSLSession()

Specified by:

getSSLSession in interface HttpConnection

getEndpointDetails

public EndpointDetails getEndpointDetails()

Specified by:

getEndpointDetails in interface HttpConnection

getSocketTimeout

public Timeout getSocketTimeout()

Specified by:

getSocketTimeout in interface SocketModalCloseable

getProtocolVersion

public ProtocolVersion getProtocolVersion()

Specified by:

getProtocolVersion in interface HttpConnection

getRemoteAddress

public SocketAddress getRemoteAddress()

Specified by:

getRemoteAddress in interface HttpConnection

getLocalAddress

public SocketAddress getLocalAddress()

Specified by:

getLocalAddress in interface HttpConnection