public final class oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner extends java.lang.Object
{
private final boolean allMustSucceed;
private final oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList futures;
private void <init>(boolean, oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList)
{
oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner v;
oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList v;
boolean v;
v := @this: oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner;
v := @parameter: boolean;
v := @parameter: oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner: boolean allMustSucceed> = v;
v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner: oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList futures> = v;
return;
}
public oadd.org.apache.curator.shaded.com.google.common.util.concurrent.ListenableFuture callAsync(oadd.org.apache.curator.shaded.com.google.common.util.concurrent.AsyncCallable, java.util.concurrent.Executor)
{
oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner v;
java.util.concurrent.Executor v;
oadd.org.apache.curator.shaded.com.google.common.util.concurrent.CombinedFuture v;
oadd.org.apache.curator.shaded.com.google.common.util.concurrent.AsyncCallable v;
oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList v;
boolean v;
v := @this: oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner;
v := @parameter: oadd.org.apache.curator.shaded.com.google.common.util.concurrent.AsyncCallable;
v := @parameter: java.util.concurrent.Executor;
v = new oadd.org.apache.curator.shaded.com.google.common.util.concurrent.CombinedFuture;
v = v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner: oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList futures>;
v = v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner: boolean allMustSucceed>;
specialinvoke v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.CombinedFuture: void <init>(oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableCollection,boolean,java.util.concurrent.Executor,oadd.org.apache.curator.shaded.com.google.common.util.concurrent.AsyncCallable)>(v, v, v, v);
return v;
}
public oadd.org.apache.curator.shaded.com.google.common.util.concurrent.ListenableFuture call(java.util.concurrent.Callable, java.util.concurrent.Executor)
{
oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner v;
java.util.concurrent.Executor v;
oadd.org.apache.curator.shaded.com.google.common.util.concurrent.CombinedFuture v;
java.util.concurrent.Callable v;
oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList v;
boolean v;
v := @this: oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner;
v := @parameter: java.util.concurrent.Callable;
v := @parameter: java.util.concurrent.Executor;
v = new oadd.org.apache.curator.shaded.com.google.common.util.concurrent.CombinedFuture;
v = v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner: oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList futures>;
v = v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner: boolean allMustSucceed>;
specialinvoke v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.CombinedFuture: void <init>(oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableCollection,boolean,java.util.concurrent.Executor,java.util.concurrent.Callable)>(v, v, v, v);
return v;
}
public oadd.org.apache.curator.shaded.com.google.common.util.concurrent.ListenableFuture run(java.lang.Runnable, java.util.concurrent.Executor)
{
oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner v;
java.util.concurrent.Executor v;
oadd.org.apache.curator.shaded.com.google.common.util.concurrent.ListenableFuture v;
oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner$1 v;
java.lang.Runnable v;
v := @this: oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner;
v := @parameter: java.lang.Runnable;
v := @parameter: java.util.concurrent.Executor;
v = new oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner$1;
specialinvoke v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner$1: void <init>(oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner,java.lang.Runnable)>(v, v);
v = virtualinvoke v.<oadd.org.apache.curator.shaded.com.google.common.util.concurrent.Futures$FutureCombiner: oadd.org.apache.curator.shaded.com.google.common.util.concurrent.ListenableFuture call(java.util.concurrent.Callable,java.util.concurrent.Executor)>(v, v);
return v;
}
}