public abstract class org.apache.kafkaesqueesque.common.KafkaFuture extends java.lang.Object implements java.util.concurrent.Future
{
public void <init>()
{
org.apache.kafkaesqueesque.common.KafkaFuture v;
v := @this: org.apache.kafkaesqueesque.common.KafkaFuture;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.kafkaesqueesque.common.KafkaFuture completedFuture(java.lang.Object)
{
java.lang.Object v;
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
v := @parameter: java.lang.Object;
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.KafkaFuture: boolean complete(java.lang.Object)>(v);
return v;
}
public static transient org.apache.kafkaesqueesque.common.KafkaFuture allOf(org.apache.kafkaesqueesque.common.KafkaFuture[])
{
org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl v;
int v, v, v;
org.apache.kafkaesqueesque.common.KafkaFuture[] v;
org.apache.kafkaesqueesque.common.KafkaFuture$AllOfAdapter v;
org.apache.kafkaesqueesque.common.KafkaFuture v;
v := @parameter: org.apache.kafkaesqueesque.common.KafkaFuture[];
v = new org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl;
specialinvoke v.<org.apache.kafkaesqueesque.common.internals.KafkaFutureImpl: void <init>()>();
v = new org.apache.kafkaesqueesque.common.KafkaFuture$AllOfAdapter;
v = lengthof v;
specialinvoke v.<org.apache.kafkaesqueesque.common.KafkaFuture$AllOfAdapter: void <init>(int,org.apache.kafkaesqueesque.common.KafkaFuture)>(v, v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.apache.kafkaesqueesque.common.KafkaFuture: void addWaiter(org.apache.kafkaesqueesque.common.KafkaFuture$BiConsumer)>(v);
v = v + 1;
goto label;
label:
return v;
}
public abstract org.apache.kafkaesqueesque.common.KafkaFuture thenApply(org.apache.kafkaesqueesque.common.KafkaFuture$BaseFunction);
public abstract org.apache.kafkaesqueesque.common.KafkaFuture thenApply(org.apache.kafkaesqueesque.common.KafkaFuture$Function);
public abstract org.apache.kafkaesqueesque.common.KafkaFuture whenComplete(org.apache.kafkaesqueesque.common.KafkaFuture$BiConsumer);
protected abstract void addWaiter(org.apache.kafkaesqueesque.common.KafkaFuture$BiConsumer);
protected abstract boolean complete(java.lang.Object);
protected abstract boolean completeExceptionally(java.lang.Throwable);
public abstract boolean cancel(boolean);
public abstract java.lang.Object get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException;
public abstract java.lang.Object get(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException;
public abstract java.lang.Object getNow(java.lang.Object) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException;
public abstract boolean isCancelled();
public abstract boolean isCompletedExceptionally();
public abstract boolean isDone();
}