public class SpdyClientConnection extends Object implements ClientConnection
| Constructor and Description |
|---|
SpdyClientConnection(SpdyChannel spdyChannel, ClientStatistics clientStatistics) |
| Modifier and Type | Method and Description |
|---|---|
void | close() |
ByteBufferPool | getBufferPool() |
org.xnio.ChannelListener.Setter<? extends ClientConnection> | getCloseSetter() |
org.xnio.XnioIoThread | getIoThread() |
SocketAddress | getLocalAddress() |
<A extends SocketAddress> | getLocalAddress(Class<A> type) |
<T> T | getOption(org.xnio.Option<T> option) |
SocketAddress | getPeerAddress() |
<A extends SocketAddress> | getPeerAddress(Class<A> type) |
ClientStatistics | getStatistics() |
org.xnio.XnioWorker | getWorker() |
boolean | isMultiplexingSupported() |
boolean | isOpen() |
boolean | isPushSupported() |
boolean | isUpgraded() |
org.xnio.StreamConnection | performUpgrade() Upgrade the connection, if the underlying protocol supports it. |
void | sendRequest(ClientRequest request, ClientCallback<ClientExchange> clientCallback) Sends a client request. |
<T> T | setOption(org.xnio.Option<T> option, T value) |
boolean | supportsOption(org.xnio.Option<?> option) |
public SpdyClientConnection(SpdyChannel spdyChannel, ClientStatistics clientStatistics)
public void sendRequest(ClientRequest request, ClientCallback<ClientExchange> clientCallback)
ClientConnection Request objects can be queued. Once the request is in a state that it is ready to be sent the clientCallback is invoked to provide the caller with the ClientExchange
If ClientConnection.isMultiplexingSupported() returns true then multiple requests may be active at the same time, and a later request may complete before an earlier one.
Note that the request header may not be written out until after the callback has been invoked. This allows the client to write out a header with a gathering write if the request contains content.
sendRequest in interface ClientConnectionrequest - The request to send.public org.xnio.StreamConnection performUpgrade()
throws IOException ClientConnectionperformUpgrade in interface ClientConnectionIOExceptionpublic ByteBufferPool getBufferPool()
getBufferPool in interface ClientConnectionpublic SocketAddress getPeerAddress()
getPeerAddress in interface ClientConnectionpublic <A extends SocketAddress> A getPeerAddress(Class<A> type)
getPeerAddress in interface ClientConnectionpublic org.xnio.ChannelListener.Setter<? extends ClientConnection> getCloseSetter()
getCloseSetter in interface ClientConnectionpublic SocketAddress getLocalAddress()
getLocalAddress in interface ClientConnectionpublic <A extends SocketAddress> A getLocalAddress(Class<A> type)
getLocalAddress in interface ClientConnectionpublic org.xnio.XnioWorker getWorker()
getWorker in interface ClientConnectionpublic org.xnio.XnioIoThread getIoThread()
getIoThread in interface ClientConnectionpublic boolean isOpen()
isOpen in interface ClientConnectionisOpen in interface Channelpublic void close()
throws IOException close in interface Closeableclose in interface AutoCloseableclose in interface ChannelIOExceptionpublic boolean supportsOption(org.xnio.Option<?> option)
supportsOption in interface ClientConnectionpublic <T> T getOption(org.xnio.Option<T> option)
throws IOException getOption in interface ClientConnectionIOExceptionpublic <T> T setOption(org.xnio.Option<T> option,
T value)
throws IllegalArgumentException,
IOException setOption in interface ClientConnectionIllegalArgumentExceptionIOExceptionpublic boolean isUpgraded()
isUpgraded in interface ClientConnectionpublic boolean isPushSupported()
isPushSupported in interface ClientConnectiontrue if this connection support server pushpublic boolean isMultiplexingSupported()
isMultiplexingSupported in interface ClientConnectiontrue if this client supports multiplexingpublic ClientStatistics getStatistics()
getStatistics in interface ClientConnectionnull if statistics are not supported or disabledCopyright © 2015 JBoss by Red Hat. All rights reserved.