private class HTTP2ClientConnectionFactory.HTTP2ClientConnection extends HTTP2Connection implements Callback
HTTP2Connection.HTTP2Producer
Callback.Completable, Callback.Completing, Callback.Nested
Invocable.InvocationType
Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo
Modifier and Type | Field and Description |
---|---|
private HTTP2Client |
client |
private Session.Listener |
listener |
private Promise<Session> |
promise |
LOG
__nonBlocking
Modifier | Constructor and Description |
---|---|
private |
HTTP2ClientConnection(HTTP2Client client,
ByteBufferPool byteBufferPool,
java.util.concurrent.Executor executor,
EndPoint endpoint,
Parser parser,
ISession session,
int bufferSize,
Promise<Session> promise,
Session.Listener listener) |
Modifier and Type | Method and Description |
---|---|
void |
failed(java.lang.Throwable x)
Callback invoked when the operation fails.
|
long |
getMessagesIn() |
long |
getMessagesOut() |
void |
onOpen()
Callback method invoked when this connection is opened.
|
void |
succeeded()
Callback invoked when the operation completes.
|
close, dispatch, getBytesIn, getBytesOut, getParser, getSession, offerTask, onClose, onFillable, onFlushed, onIdleExpired, produce, setInputBuffer
addListener, failedCallback, fillInterested, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, isFillInterested, onFillInterestedFailed, onReadTimeout, removeListener, setInputBufferSize, toConnectionString, toString, tryFillInterested, tryFillInterested
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getInvocationType, getInvocationType, invokeNonBlocking, isNonBlockingInvocation
private final HTTP2Client client
private final Session.Listener listener
private HTTP2ClientConnection(HTTP2Client client, ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, EndPoint endpoint, Parser parser, ISession session, int bufferSize, Promise<Session> promise, Session.Listener listener)
public long getMessagesIn()
getMessagesIn
in interface Connection
getMessagesIn
in class AbstractConnection
public long getMessagesOut()
getMessagesOut
in interface Connection
getMessagesOut
in class AbstractConnection
public void onOpen()
Connection
Callback method invoked when this connection is opened.
Creators of the connection implementation are responsible for calling this method.
onOpen
in interface Connection
onOpen
in class HTTP2Connection
public void succeeded()
Callback
Callback invoked when the operation completes.
succeeded
in interface Callback
Callback.failed(Throwable)