public class io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl extends java.lang.Object implements io.fabric.kubernetes.clnt.v.http.HttpClient
{
static final java.util.Map MEDIA_TYPES;
public static final okhttp.MediaType JSON;
public static final okhttp.MediaType JSON_PATCH;
public static final okhttp.MediaType STRATEGIC_MERGE_JSON_PATCH;
public static final okhttp.MediaType JSON_MERGE_PATCH;
private final okhttp.OkHttpClient httpClient;
static okhttp.MediaType parseMediaType(java.lang.String)
{
java.lang.String v;
okhttp.MediaType v;
java.util.Map v;
v := @parameter: java.lang.String;
v = staticinvoke <okhttp.MediaType: okhttp.MediaType parse(java.lang.String)>(v);
v = <io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: java.util.Map MEDIA_TYPES>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public void <init>(okhttp.OkHttpClient)
{
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl v;
okhttp.OkHttpClient v;
v := @this: io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl;
v := @parameter: okhttp.OkHttpClient;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient> = v;
return;
}
public void close()
{
okhttp.Dispatcher v, v, v;
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl v;
okhttp.OkHttpClient v, v, v, v;
okhttp.ConnectionPool v;
java.util.concurrent.ExecutorService v, v;
v := @this: io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl;
v = v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
v = virtualinvoke v.<okhttp.OkHttpClient: okhttp.ConnectionPool connectionPool()>();
v = v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
v = virtualinvoke v.<okhttp.OkHttpClient: okhttp.Dispatcher dispatcher()>();
v = v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
v = virtualinvoke v.<okhttp.OkHttpClient: okhttp.Dispatcher dispatcher()>();
if v == null goto label;
v = v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
v = virtualinvoke v.<okhttp.OkHttpClient: okhttp.Dispatcher dispatcher()>();
v = virtualinvoke v.<okhttp.Dispatcher: java.util.concurrent.ExecutorService executorService()>();
goto label;
label:
v = null;
label:
v = v;
if v == null goto label;
virtualinvoke v.<okhttp.Dispatcher: void cancelAll()>();
label:
if v == null goto label;
virtualinvoke v.<okhttp.ConnectionPool: void evictAll()>();
label:
if v == null goto label;
interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List shutdownNow()>();
label:
return;
}
public io.fabric.kubernetes.clnt.v.http.HttpResponse send(io.fabric.kubernetes.clnt.v.http.HttpRequest, java.lang.Class) throws java.io.IOException
{
okhttp.Request v;
io.fabric.kubernetes.clnt.v.http.HttpRequest v;
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl v;
okhttp.OkHttpClient v;
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl$OkHttpResponseImpl v;
okhttp.Response v;
java.lang.Class v;
okhttp.Call v;
v := @this: io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl;
v := @parameter: io.fabric.kubernetes.clnt.v.http.HttpRequest;
v := @parameter: java.lang.Class;
v = new io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl$OkHttpResponseImpl;
v = v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpRequestImpl: okhttp.Request getRequest()>();
v = virtualinvoke v.<okhttp.OkHttpClient: okhttp.Call newCall(okhttp.Request)>(v);
v = interfaceinvoke v.<okhttp.Call: okhttp.Response execute()>();
specialinvoke v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl$OkHttpResponseImpl: void <init>(okhttp.Response,java.lang.Class)>(v, v);
return v;
}
public io.fabric.kubernetes.clnt.v.http.HttpClient$Builder newBuilder()
{
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl v;
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientBuilderImpl v;
okhttp.OkHttpClient v;
okhttp.OkHttpClient$Builder v;
v := @this: io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl;
v = new io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientBuilderImpl;
v = v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
v = virtualinvoke v.<okhttp.OkHttpClient: okhttp.OkHttpClient$Builder newBuilder()>();
specialinvoke v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientBuilderImpl: void <init>(okhttp.OkHttpClient$Builder)>(v);
return v;
}
public java.util.concurrent.CompletableFuture sendAsync(io.fabric.kubernetes.clnt.v.http.HttpRequest, java.lang.Class)
{
okhttp.Request v;
java.util.concurrent.CompletableFuture v;
io.fabric.kubernetes.clnt.v.http.HttpRequest v;
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl v;
okhttp.OkHttpClient v;
java.util.function.BiConsumer v;
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl$1 v;
java.lang.Class v;
okhttp.Call v;
v := @this: io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl;
v := @parameter: io.fabric.kubernetes.clnt.v.http.HttpRequest;
v := @parameter: java.lang.Class;
v = new java.util.concurrent.CompletableFuture;
specialinvoke v.<java.util.concurrent.CompletableFuture: void <init>()>();
v = v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpRequestImpl: okhttp.Request getRequest()>();
v = virtualinvoke v.<okhttp.OkHttpClient: okhttp.Call newCall(okhttp.Request)>(v);
v = new io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl$1;
specialinvoke v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl$1: void <init>(io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl,java.util.concurrent.CompletableFuture,java.lang.Class)>(v, v, v);
interfaceinvoke v.<okhttp.Call: void enqueue(okhttp.Callback)>(v);
v = staticinvoke <io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl$lambda_sendAsync_0__203: java.util.function.BiConsumer bootstrap$(java.util.concurrent.CompletableFuture,okhttp.Call)>(v, v);
virtualinvoke v.<java.util.concurrent.CompletableFuture: java.util.concurrent.CompletableFuture whenComplete(java.util.function.BiConsumer)>(v);
return v;
}
public io.fabric.kubernetes.clnt.v.http.WebSocket$Builder newWebSocketBuilder()
{
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl v;
io.fabric.kubernetes.clnt.v.okhttp.OkHttpWebSocketImpl$BuilderImpl v;
okhttp.OkHttpClient v;
v := @this: io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl;
v = new io.fabric.kubernetes.clnt.v.okhttp.OkHttpWebSocketImpl$BuilderImpl;
v = v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
specialinvoke v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpWebSocketImpl$BuilderImpl: void <init>(okhttp.OkHttpClient)>(v);
return v;
}
public okhttp.OkHttpClient getOkHttpClient()
{
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl v;
okhttp.OkHttpClient v;
v := @this: io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl;
v = v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
return v;
}
public io.fabric.kubernetes.clnt.v.http.HttpRequest$Builder newHttpRequestBuilder()
{
io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl v;
io.fabric.kubernetes.clnt.v.okhttp.OkHttpRequestImpl$BuilderImpl v;
v := @this: io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl;
v = new io.fabric.kubernetes.clnt.v.okhttp.OkHttpRequestImpl$BuilderImpl;
specialinvoke v.<io.fabric.kubernetes.clnt.v.okhttp.OkHttpRequestImpl$BuilderImpl: void <init>()>();
return v;
}
static void <clinit>()
{
java.util.concurrent.ConcurrentHashMap v;
okhttp.MediaType v, v, v, v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: java.util.Map MEDIA_TYPES> = v;
v = staticinvoke <io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.MediaType parseMediaType(java.lang.String)>("application/json");
<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.MediaType JSON> = v;
v = staticinvoke <io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.MediaType parseMediaType(java.lang.String)>("application/json-patch+json");
<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.MediaType JSON_PATCH> = v;
v = staticinvoke <io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.MediaType parseMediaType(java.lang.String)>("application/strategic-merge-patch+json");
<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.MediaType STRATEGIC_MERGE_JSON_PATCH> = v;
v = staticinvoke <io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.MediaType parseMediaType(java.lang.String)>("application/merge-patch+json");
<io.fabric.kubernetes.clnt.v.okhttp.OkHttpClientImpl: okhttp.MediaType JSON_MERGE_PATCH> = v;
return;
}
}