abstract class com.google.common.util.concurrent.AbstractTransformFuture extends com.google.common.util.concurrent.FluentFuture$TrustedFuture implements java.lang.Runnable
{
com.google.common.util.concurrent.ListenableFuture inputFuture;
java.lang.Object function;
static com.google.common.util.concurrent.ListenableFuture create(com.google.common.util.concurrent.ListenableFuture, com.google.common.util.concurrent.AsyncFunction, java.util.concurrent.Executor)
{
com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture v;
com.google.common.util.concurrent.ListenableFuture v;
java.util.concurrent.Executor v, v;
com.google.common.util.concurrent.AsyncFunction v;
v := @parameter: com.google.common.util.concurrent.ListenableFuture;
v := @parameter: com.google.common.util.concurrent.AsyncFunction;
v := @parameter: java.util.concurrent.Executor;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v = new com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture;
specialinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture: void <init>(com.google.common.util.concurrent.ListenableFuture,com.google.common.util.concurrent.AsyncFunction)>(v, v);
v = staticinvoke <com.google.common.util.concurrent.MoreExecutors: java.util.concurrent.Executor rejectionPropagatingExecutor(java.util.concurrent.Executor,com.google.common.util.concurrent.AbstractFuture)>(v, v);
interfaceinvoke v.<com.google.common.util.concurrent.ListenableFuture: void addListener(java.lang.Runnable,java.util.concurrent.Executor)>(v, v);
return v;
}
static com.google.common.util.concurrent.ListenableFuture create(com.google.common.util.concurrent.ListenableFuture, com.google.common.base.Function, java.util.concurrent.Executor)
{
com.google.common.base.Function v;
com.google.common.util.concurrent.ListenableFuture v;
com.google.common.util.concurrent.AbstractTransformFuture$TransformFuture v;
java.util.concurrent.Executor v, v;
v := @parameter: com.google.common.util.concurrent.ListenableFuture;
v := @parameter: com.google.common.base.Function;
v := @parameter: java.util.concurrent.Executor;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v = new com.google.common.util.concurrent.AbstractTransformFuture$TransformFuture;
specialinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture$TransformFuture: void <init>(com.google.common.util.concurrent.ListenableFuture,com.google.common.base.Function)>(v, v);
v = staticinvoke <com.google.common.util.concurrent.MoreExecutors: java.util.concurrent.Executor rejectionPropagatingExecutor(java.util.concurrent.Executor,com.google.common.util.concurrent.AbstractFuture)>(v, v);
interfaceinvoke v.<com.google.common.util.concurrent.ListenableFuture: void addListener(java.lang.Runnable,java.util.concurrent.Executor)>(v, v);
return v;
}
void <init>(com.google.common.util.concurrent.ListenableFuture, java.lang.Object)
{
com.google.common.util.concurrent.AbstractTransformFuture v;
com.google.common.util.concurrent.ListenableFuture v;
java.lang.Object v, v, v;
v := @this: com.google.common.util.concurrent.AbstractTransformFuture;
v := @parameter: com.google.common.util.concurrent.ListenableFuture;
v := @parameter: java.lang.Object;
specialinvoke v.<com.google.common.util.concurrent.FluentFuture$TrustedFuture: void <init>()>();
v = staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<com.google.common.util.concurrent.AbstractTransformFuture: com.google.common.util.concurrent.ListenableFuture inputFuture> = v;
v = staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<com.google.common.util.concurrent.AbstractTransformFuture: java.lang.Object function> = v;
return;
}
public final void run()
{
java.lang.Throwable v, v, v;
com.google.common.util.concurrent.ListenableFuture v;
java.lang.Error v;
com.google.common.util.concurrent.AbstractTransformFuture v;
boolean v, v, v, v, v, v;
java.util.concurrent.CancellationException v;
java.lang.RuntimeException v;
java.util.concurrent.ExecutionException v;
java.lang.Object v, v, v;
v := @this: com.google.common.util.concurrent.AbstractTransformFuture;
v = v.<com.google.common.util.concurrent.AbstractTransformFuture: com.google.common.util.concurrent.ListenableFuture inputFuture>;
v = v.<com.google.common.util.concurrent.AbstractTransformFuture: java.lang.Object function>;
v = virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: boolean isCancelled()>();
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v | v;
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v | v;
if v == 0 goto label;
return;
label:
v.<com.google.common.util.concurrent.AbstractTransformFuture: com.google.common.util.concurrent.ListenableFuture inputFuture> = null;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListenableFuture: boolean isCancelled()>();
if v == 0 goto label;
virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: boolean setFuture(com.google.common.util.concurrent.ListenableFuture)>(v);
return;
label:
v = staticinvoke <com.google.common.util.concurrent.Futures: java.lang.Object getDone(java.util.concurrent.Future)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: boolean cancel(boolean)>(0);
return;
label:
v := @caughtexception;
v = virtualinvoke v.<java.util.concurrent.ExecutionException: java.lang.Throwable getCause()>();
virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: boolean setException(java.lang.Throwable)>(v);
return;
label:
v := @caughtexception;
virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: boolean setException(java.lang.Throwable)>(v);
return;
label:
v := @caughtexception;
virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: boolean setException(java.lang.Throwable)>(v);
return;
label:
v = virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: java.lang.Object doTransform(java.lang.Object,java.lang.Object)>(v, v);
label:
v.<com.google.common.util.concurrent.AbstractTransformFuture: java.lang.Object function> = null;
goto label;
label:
v := @caughtexception;
virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: boolean setException(java.lang.Throwable)>(v);
label:
v.<com.google.common.util.concurrent.AbstractTransformFuture: java.lang.Object function> = null;
return;
label:
v := @caughtexception;
v.<com.google.common.util.concurrent.AbstractTransformFuture: java.lang.Object function> = null;
throw v;
label:
virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: void setResult(java.lang.Object)>(v);
return;
catch java.util.concurrent.CancellationException from label to label with label;
catch java.util.concurrent.ExecutionException from label to label with label;
catch java.lang.RuntimeException from label to label with label;
catch java.lang.Error from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
abstract java.lang.Object doTransform(java.lang.Object, java.lang.Object) throws java.lang.Exception;
abstract void setResult(java.lang.Object);
protected final void afterDone()
{
com.google.common.util.concurrent.AbstractTransformFuture v;
com.google.common.util.concurrent.ListenableFuture v;
v := @this: com.google.common.util.concurrent.AbstractTransformFuture;
v = v.<com.google.common.util.concurrent.AbstractTransformFuture: com.google.common.util.concurrent.ListenableFuture inputFuture>;
virtualinvoke v.<com.google.common.util.concurrent.AbstractTransformFuture: void maybePropagateCancellationTo(java.util.concurrent.Future)>(v);
v.<com.google.common.util.concurrent.AbstractTransformFuture: com.google.common.util.concurrent.ListenableFuture inputFuture> = null;
v.<com.google.common.util.concurrent.AbstractTransformFuture: java.lang.Object function> = null;
return;
}
protected java.lang.String pendingToString()
{
com.google.common.util.concurrent.ListenableFuture v;
com.google.common.util.concurrent.AbstractTransformFuture v;
int v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v;
java.lang.StringBuilder v, v;
v := @this: com.google.common.util.concurrent.AbstractTransformFuture;
v = v.<com.google.common.util.concurrent.AbstractTransformFuture: com.google.common.util.concurrent.ListenableFuture inputFuture>;
v = v.<com.google.common.util.concurrent.AbstractTransformFuture: java.lang.Object function>;
v = specialinvoke v.<com.google.common.util.concurrent.FluentFuture$TrustedFuture: java.lang.String pendingToString()>();
v = "";
if v == null goto label;
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: int length()>();
v = 16 + v;
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("inputFuture=[\u], ");
label:
if v == null goto label;
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: int length()>();
v = 11 + v;
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: int length()>();
v = v + v;
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001function=[\u]");
return v;
label:
if v == null goto label;
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: int length()>();
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String concat(java.lang.String)>(v);
goto label;
label:
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(java.lang.String)>(v);
label:
return v;
label:
return null;
}
}