@Internal public class ClientH2StreamMultiplexer extends Object
ProtocolIOSession
that implements
client side HTTP/2 messaging protocol with full support for
multiplexed message transmission.Constructor and Description |
---|
ClientH2StreamMultiplexer(ProtocolIOSession ioSession,
FrameFactory frameFactory,
HttpProcessor httpProcessor,
HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
H2Config h2Config,
CharCodingConfig charCodingConfig,
H2StreamListener streamListener) |
ClientH2StreamMultiplexer(ProtocolIOSession ioSession,
HttpProcessor httpProcessor,
H2Config h2Config,
CharCodingConfig charCodingConfig) |
ClientH2StreamMultiplexer(ProtocolIOSession ioSession,
HttpProcessor httpProcessor,
HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
H2Config h2Config,
CharCodingConfig charCodingConfig) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
close(CloseMode closeMode) |
EndpointDetails |
getEndpointDetails() |
String |
getId() |
SocketAddress |
getLocalAddress() |
ProtocolVersion |
getProtocolVersion() |
SocketAddress |
getRemoteAddress() |
Timeout |
getSocketTimeout() |
SSLSession |
getSSLSession() |
boolean |
isOpen() |
void |
onConnect() |
void |
onDisconnect() |
void |
onException(Exception cause) |
void |
onInput(ByteBuffer src) |
void |
onOutput() |
void |
onTimeout(Timeout timeout) |
void |
setSocketTimeout(Timeout timeout) |
String |
toString() |
public ClientH2StreamMultiplexer(ProtocolIOSession ioSession, FrameFactory frameFactory, HttpProcessor httpProcessor, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, H2Config h2Config, CharCodingConfig charCodingConfig, H2StreamListener streamListener)
public ClientH2StreamMultiplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, H2Config h2Config, CharCodingConfig charCodingConfig)
public ClientH2StreamMultiplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, H2Config h2Config, CharCodingConfig charCodingConfig)
public String getId()
getId
in interface Identifiable
public final void onConnect() throws HttpException, IOException
HttpException
IOException
public final void onInput(ByteBuffer src) throws HttpException, IOException
HttpException
IOException
public final void onOutput() throws HttpException, IOException
HttpException
IOException
public final void onTimeout(Timeout timeout) throws HttpException, IOException
HttpException
IOException
public final void onDisconnect()
public final void onException(Exception cause)
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in interface HttpConnection
IOException
public void close(CloseMode closeMode)
close
in interface ModalCloseable
public boolean isOpen()
isOpen
in interface HttpConnection
public void setSocketTimeout(Timeout timeout)
setSocketTimeout
in interface SocketModalCloseable
public SSLSession getSSLSession()
getSSLSession
in interface HttpConnection
public EndpointDetails getEndpointDetails()
getEndpointDetails
in interface HttpConnection
public Timeout getSocketTimeout()
getSocketTimeout
in interface SocketModalCloseable
public ProtocolVersion getProtocolVersion()
getProtocolVersion
in interface HttpConnection
public SocketAddress getRemoteAddress()
getRemoteAddress
in interface HttpConnection
public SocketAddress getLocalAddress()
getLocalAddress
in interface HttpConnection
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.