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() |
ChannelListener.Setter<? extends ClientConnection> |
getCloseSetter() |
XnioIoThread |
getIoThread() |
SocketAddress |
getLocalAddress() |
<A extends SocketAddress> |
getLocalAddress(Class<A> type) |
<T> T |
getOption(Option<T> option) |
SocketAddress |
getPeerAddress() |
<A extends SocketAddress> |
getPeerAddress(Class<A> type) |
ClientStatistics |
getStatistics() |
XnioWorker |
getWorker() |
boolean |
isMultiplexingSupported() |
boolean |
isOpen() |
boolean |
isPushSupported() |
boolean |
isUpgraded() |
boolean |
isUpgradeSupported() |
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(Option<T> option,
T value) |
boolean |
supportsOption(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 ClientConnection
request
- The request to send.public StreamConnection performUpgrade() throws IOException
ClientConnection
performUpgrade
in interface ClientConnection
IOException
public ByteBufferPool getBufferPool()
getBufferPool
in interface ClientConnection
public SocketAddress getPeerAddress()
getPeerAddress
in interface ClientConnection
public <A extends SocketAddress> A getPeerAddress(Class<A> type)
getPeerAddress
in interface ClientConnection
public ChannelListener.Setter<? extends ClientConnection> getCloseSetter()
getCloseSetter
in interface ClientConnection
public SocketAddress getLocalAddress()
getLocalAddress
in interface ClientConnection
public <A extends SocketAddress> A getLocalAddress(Class<A> type)
getLocalAddress
in interface ClientConnection
public XnioWorker getWorker()
getWorker
in interface ClientConnection
public XnioIoThread getIoThread()
getIoThread
in interface ClientConnection
public boolean isOpen()
isOpen
in interface ClientConnection
isOpen
in interface Channel
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in interface Channel
IOException
public boolean supportsOption(Option<?> option)
supportsOption
in interface ClientConnection
public <T> T getOption(Option<T> option) throws IOException
getOption
in interface ClientConnection
IOException
public <T> T setOption(Option<T> option, T value) throws IllegalArgumentException, IOException
setOption
in interface ClientConnection
IllegalArgumentException
IOException
public boolean isUpgraded()
isUpgraded
in interface ClientConnection
public boolean isPushSupported()
isPushSupported
in interface ClientConnection
true
if this connection support server pushpublic boolean isMultiplexingSupported()
isMultiplexingSupported
in interface ClientConnection
true
if this client supports multiplexingpublic ClientStatistics getStatistics()
getStatistics
in interface ClientConnection
null
if statistics are not supported or disabledpublic boolean isUpgradeSupported()
isUpgradeSupported
in interface ClientConnection
Copyright © 2016 JBoss by Red Hat. All rights reserved.