private static class ProxyProtocolClientConnectionFactory.ProxyProtocolConnectionV1 extends ProxyProtocolClientConnectionFactory.ProxyProtocolConnection
Callback.Completable, Callback.Completing, Callback.InvocableCallback, Callback.NestedInvocable.InvocationTypeConnection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo| Modifier and Type | Field and Description |
|---|---|
private ProxyProtocolClientConnectionFactory.V1.Tag |
tag |
LOG__nonBlocking| Constructor and Description |
|---|
ProxyProtocolConnectionV1(EndPoint endPoint,
java.util.concurrent.Executor executor,
ClientConnectionFactory factory,
java.util.Map<java.lang.String,java.lang.Object> context,
ProxyProtocolClientConnectionFactory.V1.Tag tag) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
writePROXYBytes(EndPoint endPoint,
Callback callback) |
failed, getInvocationType, onFillable, onOpen, succeededaddListener, close, failedCallback, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, isFillInterested, onClose, onFillInterestedFailed, onIdleExpired, onReadTimeout, removeListener, setInputBufferSize, toConnectionString, toString, tryFillInterested, tryFillInterestedclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitcombine, from, from, from, from, from, fromcombine, getInvocationType, invokeNonBlocking, isNonBlockingInvocationprivate final ProxyProtocolClientConnectionFactory.V1.Tag tag
public ProxyProtocolConnectionV1(EndPoint endPoint, java.util.concurrent.Executor executor, ClientConnectionFactory factory, java.util.Map<java.lang.String,java.lang.Object> context, ProxyProtocolClientConnectionFactory.V1.Tag tag)
protected void writePROXYBytes(EndPoint endPoint, Callback callback)
writePROXYBytes in class ProxyProtocolClientConnectionFactory.ProxyProtocolConnection