private static class ProxyProtocolClientConnectionFactory.ProxyProtocolConnectionV1 extends ProxyProtocolClientConnectionFactory.ProxyProtocolConnection
Callback.Completable, Callback.Completing, Callback.InvocableCallback, Callback.Nested
Invocable.InvocationType
Connection.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, succeeded
addListener, close, failedCallback, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, isFillInterested, onClose, onFillInterestedFailed, onIdleExpired, onReadTimeout, removeListener, setInputBufferSize, toConnectionString, toString, tryFillInterested, tryFillInterested
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
combine, from, from, from, from, from, from
combine, getInvocationType, invokeNonBlocking, isNonBlockingInvocation
private 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