abstract class io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody extends java.lang.Object implements io.fabric.kubernetes.client.http.HttpClient$AsyncBody
{
private final io.fabric.kubernetes.client.http.HttpClient$BodyConsumer consumer;
private final okio.BufferedSource source;
private final java.util.concurrent.CompletableFuture done;
final io.fabric.kubernetes.client.okhttp.OkHttpClientImpl this$0;
private void <init>(io.fabric.kubernetes.client.okhttp.OkHttpClientImpl, io.fabric.kubernetes.client.http.HttpClient$BodyConsumer, okio.BufferedSource)
{
okio.BufferedSource v;
io.fabric.kubernetes.client.okhttp.OkHttpClientImpl v;
java.util.concurrent.CompletableFuture v;
io.fabric.kubernetes.client.http.HttpClient$BodyConsumer v;
io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody;
v := @parameter: io.fabric.kubernetes.client.okhttp.OkHttpClientImpl;
v := @parameter: io.fabric.kubernetes.client.http.HttpClient$BodyConsumer;
v := @parameter: okio.BufferedSource;
v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: io.fabric.kubernetes.client.okhttp.OkHttpClientImpl this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.CompletableFuture;
specialinvoke v.<java.util.concurrent.CompletableFuture: void <init>()>();
v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: java.util.concurrent.CompletableFuture done> = v;
v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: io.fabric.kubernetes.client.http.HttpClient$BodyConsumer consumer> = v;
v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: okio.BufferedSource source> = v;
return;
}
public void consume()
{
java.lang.Object[] v;
io.fabric.kubernetes.client.okhttp.OkHttpClientImpl v;
java.util.concurrent.CompletableFuture v;
java.lang.Runnable v;
java.lang.Exception v;
io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody v;
okhttp.Dispatcher v;
okio.BufferedSource v;
okhttp.OkHttpClient v;
java.util.concurrent.ExecutorService v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody;
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: io.fabric.kubernetes.client.okhttp.OkHttpClientImpl this$0>;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl: okhttp.OkHttpClient httpClient>;
v = virtualinvoke v.<okhttp.OkHttpClient: okhttp.Dispatcher dispatcher()>();
v = virtualinvoke v.<okhttp.Dispatcher: java.util.concurrent.ExecutorService executorService()>();
v = staticinvoke <io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody$lambda_consume_0__5: java.lang.Runnable bootstrap$(io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody)>(v);
interfaceinvoke v.<java.util.concurrent.ExecutorService: void execute(java.lang.Runnable)>(v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.io.Closeable)[1];
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: okio.BufferedSource source>;
v[0] = v;
staticinvoke <io.fabric.kubernetes.client.utils.Utils: void closeQuietly(java.io.Closeable[])>(v);
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: java.util.concurrent.CompletableFuture done>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean completeExceptionally(java.lang.Throwable)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
}
public java.util.concurrent.CompletableFuture done()
{
java.util.concurrent.CompletableFuture v;
io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: java.util.concurrent.CompletableFuture done>;
return v;
}
protected abstract java.lang.Object process(okio.BufferedSource) throws java.io.IOException;
public void cancel()
{
okio.BufferedSource v;
java.lang.Object[] v;
java.util.concurrent.CompletableFuture v;
io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody;
v = newarray (java.io.Closeable)[1];
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: okio.BufferedSource source>;
v[0] = v;
staticinvoke <io.fabric.kubernetes.client.utils.Utils: void closeQuietly(java.io.Closeable[])>(v);
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpAsyncBody: java.util.concurrent.CompletableFuture done>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean cancel(boolean)>(0);
return;
}
}