class io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 extends okhttp.WebSocketListener
{
private volatile boolean opened;
final java.util.concurrent.CompletableFuture val$future;
final io.fabric.kubernetes.client.http.WebSocket$Listener val$listener;
final io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl this$0;
void <init>(io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl, java.util.concurrent.CompletableFuture, io.fabric.kubernetes.client.http.WebSocket$Listener)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
java.util.concurrent.CompletableFuture v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl;
v := @parameter: java.util.concurrent.CompletableFuture;
v := @parameter: io.fabric.kubernetes.client.http.WebSocket$Listener;
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl this$0> = v;
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.CompletableFuture val$future> = v;
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener> = v;
specialinvoke v.<okhttp.WebSocketListener: void <init>()>();
return;
}
public void onFailure(okhttp.WebSocket, java.lang.Throwable, okhttp.Response)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
java.lang.Throwable v;
java.io.IOException v;
java.util.concurrent.CompletableFuture v;
okhttp.WebSocket v;
io.fabric.kubernetes.client.http.WebSocketHandshakeException v, v;
io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpResponseImpl v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
okhttp.Response v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
boolean v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: java.lang.Throwable;
v := @parameter: okhttp.Response;
if v == null goto label;
virtualinvoke v.<okhttp.Response: void close()>();
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: boolean opened>;
if v != 0 goto label;
if v == null goto label;
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.CompletableFuture val$future>;
v = new io.fabric.kubernetes.client.http.WebSocketHandshakeException;
v = new io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpResponseImpl;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpResponseImpl: void <init>(okhttp.Response,java.lang.Class)>(v, null);
specialinvoke v.<io.fabric.kubernetes.client.http.WebSocketHandshakeException: void <init>(io.fabric.kubernetes.client.http.HttpResponse)>(v);
v = virtualinvoke v.<io.fabric.kubernetes.client.http.WebSocketHandshakeException: io.fabric.kubernetes.client.http.WebSocketHandshakeException initCause(java.lang.Throwable)>(v);
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean completeExceptionally(java.lang.Throwable)>(v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket)>(v);
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onError(io.fabric.kubernetes.client.http.WebSocket,java.lang.Throwable)>(v, v);
label:
return;
catch java.io.IOException from label to label with label;
}
public void onOpen(okhttp.WebSocket, okhttp.Response)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
okhttp.Response v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
java.util.concurrent.CompletableFuture v;
okhttp.WebSocket v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: okhttp.Response;
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: boolean opened> = 1;
if v == null goto label;
virtualinvoke v.<okhttp.Response: void close()>();
label:
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket)>(v);
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.CompletableFuture val$future>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean complete(java.lang.Object)>(v);
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onOpen(io.fabric.kubernetes.client.http.WebSocket)>(v);
return;
}
public void onMessage(okhttp.WebSocket, okio.ByteString)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
okio.ByteString v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
okhttp.WebSocket v;
java.nio.ByteBuffer v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: okio.ByteString;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket)>(v);
v = virtualinvoke v.<okio.ByteString: java.nio.ByteBuffer asByteBuffer()>();
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onMessage(io.fabric.kubernetes.client.http.WebSocket,java.nio.ByteBuffer)>(v, v);
return;
}
public void onMessage(okhttp.WebSocket, java.lang.String)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
okhttp.WebSocket v;
java.lang.String v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: java.lang.String;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket)>(v);
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onMessage(io.fabric.kubernetes.client.http.WebSocket,java.lang.String)>(v, v);
return;
}
public void onClosing(okhttp.WebSocket, int, java.lang.String)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
int v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
okhttp.WebSocket v;
java.lang.String v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: int;
v := @parameter: java.lang.String;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket)>(v);
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onClose(io.fabric.kubernetes.client.http.WebSocket,int,java.lang.String)>(v, v, v);
return;
}
}