class io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler extends io.netty.channel.ChannelInboundHandlerAdapter
{
final io.netty.channel.ChannelPipeline val$pipeline;
final io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream this$0;
void <init>(io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream, io.netty.channel.ChannelPipeline)
{
io.netty.channel.ChannelPipeline v;
io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler v;
io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream v;
v := @this: io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler;
v := @parameter: io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream;
v := @parameter: io.netty.channel.ChannelPipeline;
v.<io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler: io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream this$0> = v;
v.<io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler: io.netty.channel.ChannelPipeline val$pipeline> = v;
specialinvoke v.<io.netty.channel.ChannelInboundHandlerAdapter: void <init>()>();
return;
}
public void userEventTriggered(io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception
{
io.netty.channel.ChannelPipeline v;
io.vertx.core.http.impl.Http2UpgradeClientConnection v;
io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler v;
io.netty.channel.ChannelHandlerContext v, v;
int[] v;
io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream v, v;
int v, v;
io.netty.channel.ChannelHandler v;
java.lang.Object v;
io.vertx.core.http.impl.Http1xClientConnection v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: java.lang.Object;
specialinvoke v.<io.netty.channel.ChannelInboundHandlerAdapter: void userEventTriggered(io.netty.channel.ChannelHandlerContext,java.lang.Object)>(v, v);
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPipeline pipeline()>();
v = v instanceof io.netty.handler.codec.http.HttpClientUpgradeHandler$UpgradeEvent;
if v == 0 goto label;
v = <io.vertx.core.http.impl.Http2UpgradeClientConnection$1: int[] $SwitchMap$io$netty$handler$codec$http$HttpClientUpgradeHandler$UpgradeEvent>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpClientUpgradeHandler$UpgradeEvent: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = v.<io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler: io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream this$0>;
v = v.<io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream: io.vertx.core.http.impl.Http1xClientConnection upgradingConnection>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xClientConnection: io.netty.channel.ChannelHandlerContext channelHandlerContext()>();
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelHandler handler()>();
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline remove(io.netty.channel.ChannelHandler)>(v);
label:
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline remove(io.netty.channel.ChannelHandler)>(v);
v = v.<io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler: io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream this$0>;
v = v.<io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream: io.vertx.core.http.impl.Http2UpgradeClientConnection upgradedConnection>;
v.<io.vertx.core.http.impl.Http2UpgradeClientConnection: boolean upgradeProcessed> = 1;
label:
return;
}
public void channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception
{
io.vertx.core.MultiMap v;
io.netty.util.AsciiString v, v;
io.netty.handler.codec.http.HttpResponseStatus v;
io.netty.channel.ChannelPipeline v;
io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler v;
io.netty.channel.ChannelHandlerContext v;
int v, v;
java.lang.Object v;
boolean v;
v := @this: io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: java.lang.Object;
v = v instanceof io.vertx.core.http.impl.HttpResponseHead;
if v == 0 goto label;
v = v.<io.vertx.core.http.impl.Http2UpgradeClientConnection$UpgradingStream$1UpgradeRequestHandler: io.netty.channel.ChannelPipeline val$pipeline>;
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline remove(io.netty.channel.ChannelHandler)>(v);
v = v.<io.vertx.core.http.impl.HttpResponseHead: int statusCode>;
v = <io.netty.handler.codec.http.HttpResponseStatus: io.netty.handler.codec.http.HttpResponseStatus SWITCHING_PROTOCOLS>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpResponseStatus: int code()>();
if v == v goto label;
v = v.<io.vertx.core.http.impl.HttpResponseHead: io.vertx.core.MultiMap headers>;
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString CONNECTION>;
v = <io.netty.handler.codec.http.HttpHeaderValues: io.netty.util.AsciiString CLOSE>;
interfaceinvoke v.<io.vertx.core.MultiMap: io.vertx.core.MultiMap set(java.lang.CharSequence,java.lang.CharSequence)>(v, v);
label:
specialinvoke v.<io.netty.channel.ChannelInboundHandlerAdapter: void channelRead(io.netty.channel.ChannelHandlerContext,java.lang.Object)>(v, v);
return;
}
}