public final class com.google.common.util.concurrent.Futures extends com.google.common.util.concurrent.GwtFuturesCatchingSpecialization
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: com.google.common.util.concurrent.Futures
super_class: com.google.common.util.concurrent.GwtFuturesCatchingSpecialization
{
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial com.google.common.util.concurrent.GwtFuturesCatchingSpecialization.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/google/common/util/concurrent/Futures;
public static <V, X extends java.lang.Exception> com.google.common.util.concurrent.CheckedFuture<V, X> makeChecked(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.base.Function<? super java.lang.Exception, X>);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/base/Function;)Lcom/google/common/util/concurrent/CheckedFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new com.google.common.util.concurrent.Futures$MappingCheckedFuture
dup
aload 0
invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.google.common.util.concurrent.ListenableFuture
aload 1
invokespecial com.google.common.util.concurrent.Futures$MappingCheckedFuture.<init>:(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/base/Function;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 future Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
0 1 1 mapper Lcom/google/common/base/Function<-Ljava/lang/Exception;TX;>;
Signature: <V:Ljava/lang/Object;X:Ljava/lang/Exception;>(Lcom/google/common/util/concurrent/ListenableFuture<TV;>;Lcom/google/common/base/Function<-Ljava/lang/Exception;TX;>;)Lcom/google/common/util/concurrent/CheckedFuture<TV;TX;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
future
mapper
public static <V> com.google.common.util.concurrent.ListenableFuture<V> immediateFuture(V);
descriptor: (Ljava/lang/Object;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
ifnonnull 3
1: getstatic com.google.common.util.concurrent.ImmediateFuture$ImmediateSuccessfulFuture.NULL:Lcom/google/common/util/concurrent/ImmediateFuture$ImmediateSuccessfulFuture;
astore 1
start local 1 2: aload 1
areturn
end local 1 3: StackMap locals:
StackMap stack:
new com.google.common.util.concurrent.ImmediateFuture$ImmediateSuccessfulFuture
dup
aload 0
invokespecial com.google.common.util.concurrent.ImmediateFuture$ImmediateSuccessfulFuture.<init>:(Ljava/lang/Object;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 value TV;
2 3 1 typedNull Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
Signature: <V:Ljava/lang/Object;>(TV;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
org.checkerframework.checker.nullness.qual.Nullable()
MethodParameters:
Name Flags
value
public static <V, X extends java.lang.Exception> com.google.common.util.concurrent.CheckedFuture<V, X> immediateCheckedFuture(V);
descriptor: (Ljava/lang/Object;)Lcom/google/common/util/concurrent/CheckedFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.google.common.util.concurrent.ImmediateFuture$ImmediateSuccessfulCheckedFuture
dup
aload 0
invokespecial com.google.common.util.concurrent.ImmediateFuture$ImmediateSuccessfulCheckedFuture.<init>:(Ljava/lang/Object;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 value TV;
Signature: <V:Ljava/lang/Object;X:Ljava/lang/Exception;>(TV;)Lcom/google/common/util/concurrent/CheckedFuture<TV;TX;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
org.checkerframework.checker.nullness.qual.Nullable()
MethodParameters:
Name Flags
value
public static <V> com.google.common.util.concurrent.ListenableFuture<V> immediateFailedFuture(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: new com.google.common.util.concurrent.ImmediateFuture$ImmediateFailedFuture
dup
aload 0
invokespecial com.google.common.util.concurrent.ImmediateFuture$ImmediateFailedFuture.<init>:(Ljava/lang/Throwable;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 throwable Ljava/lang/Throwable;
Signature: <V:Ljava/lang/Object;>(Ljava/lang/Throwable;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
MethodParameters:
Name Flags
throwable
public static <V> com.google.common.util.concurrent.ListenableFuture<V> immediateCancelledFuture();
descriptor: ()Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new com.google.common.util.concurrent.ImmediateFuture$ImmediateCancelledFuture
dup
invokespecial com.google.common.util.concurrent.ImmediateFuture$ImmediateCancelledFuture.<init>:()V
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <V:Ljava/lang/Object;>()Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
public static <V, X extends java.lang.Exception> com.google.common.util.concurrent.CheckedFuture<V, X> immediateFailedCheckedFuture(X);
descriptor: (Ljava/lang/Exception;)Lcom/google/common/util/concurrent/CheckedFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: new com.google.common.util.concurrent.ImmediateFuture$ImmediateFailedCheckedFuture
dup
aload 0
invokespecial com.google.common.util.concurrent.ImmediateFuture$ImmediateFailedCheckedFuture.<init>:(Ljava/lang/Exception;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 exception TX;
Signature: <V:Ljava/lang/Object;X:Ljava/lang/Exception;>(TX;)Lcom/google/common/util/concurrent/CheckedFuture<TV;TX;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
exception
public static <O> com.google.common.util.concurrent.ListenableFuture<O> submitAsync(com.google.common.util.concurrent.AsyncCallable<O>, java.util.concurrent.Executor);
descriptor: (Lcom/google/common/util/concurrent/AsyncCallable;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokestatic com.google.common.util.concurrent.TrustedListenableFutureTask.create:(Lcom/google/common/util/concurrent/AsyncCallable;)Lcom/google/common/util/concurrent/TrustedListenableFutureTask;
astore 2
start local 2 1: aload 1
aload 2
invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 callable Lcom/google/common/util/concurrent/AsyncCallable<TO;>;
0 3 1 executor Ljava/util/concurrent/Executor;
1 3 2 task Lcom/google/common/util/concurrent/TrustedListenableFutureTask<TO;>;
Signature: <O:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/AsyncCallable<TO;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture<TO;>;
MethodParameters:
Name Flags
callable
executor
public static <O> com.google.common.util.concurrent.ListenableFuture<O> scheduleAsync(com.google.common.util.concurrent.AsyncCallable<O>, long, java.util.concurrent.TimeUnit, java.util.concurrent.ScheduledExecutorService);
descriptor: (Lcom/google/common/util/concurrent/AsyncCallable;JLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=7, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 0
invokestatic com.google.common.util.concurrent.TrustedListenableFutureTask.create:(Lcom/google/common/util/concurrent/AsyncCallable;)Lcom/google/common/util/concurrent/TrustedListenableFutureTask;
astore 5
start local 5 1: aload 4
aload 5
lload 1
aload 3
invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 6
start local 6 2: aload 5
3: new com.google.common.util.concurrent.Futures$1
dup
aload 6
invokespecial com.google.common.util.concurrent.Futures$1.<init>:(Ljava/util/concurrent/Future;)V
4: invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
5: invokevirtual com.google.common.util.concurrent.TrustedListenableFutureTask.addListener:(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
6: aload 5
areturn
end local 6 end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 callable Lcom/google/common/util/concurrent/AsyncCallable<TO;>;
0 7 1 delay J
0 7 3 timeUnit Ljava/util/concurrent/TimeUnit;
0 7 4 executorService Ljava/util/concurrent/ScheduledExecutorService;
1 7 5 task Lcom/google/common/util/concurrent/TrustedListenableFutureTask<TO;>;
2 7 6 scheduled Ljava/util/concurrent/Future<*>;
Signature: <O:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/AsyncCallable<TO;>;JLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/common/util/concurrent/ListenableFuture<TO;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
callable
delay
timeUnit
executorService
public static <V, X extends java.lang.Throwable> com.google.common.util.concurrent.ListenableFuture<V> catching(com.google.common.util.concurrent.ListenableFuture<? extends V>, java.lang.Class<X>, com.google.common.base.Function<? super X, ? extends V>);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Ljava/lang/Class;Lcom/google/common/base/Function;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
invokestatic com.google.common.util.concurrent.AbstractCatchingFuture.create:(Lcom/google/common/util/concurrent/ListenableFuture;Ljava/lang/Class;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 input Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;
0 1 1 exceptionType Ljava/lang/Class<TX;>;
0 1 2 fallback Lcom/google/common/base/Function<-TX;+TV;>;
Signature: <V:Ljava/lang/Object;X:Ljava/lang/Throwable;>(Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;Ljava/lang/Class<TX;>;Lcom/google/common/base/Function<-TX;+TV;>;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.DoNotCall()
com.google.common.util.concurrent.Partially$GwtIncompatible(value = "AVAILABLE but requires exceptionType to be Throwable.class")
MethodParameters:
Name Flags
input
exceptionType
fallback
public static <V, X extends java.lang.Throwable> com.google.common.util.concurrent.ListenableFuture<V> catching(com.google.common.util.concurrent.ListenableFuture<? extends V>, java.lang.Class<X>, com.google.common.base.Function<? super X, ? extends V>, java.util.concurrent.Executor);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Ljava/lang/Class;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
invokestatic com.google.common.util.concurrent.AbstractCatchingFuture.create:(Lcom/google/common/util/concurrent/ListenableFuture;Ljava/lang/Class;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 input Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;
0 1 1 exceptionType Ljava/lang/Class<TX;>;
0 1 2 fallback Lcom/google/common/base/Function<-TX;+TV;>;
0 1 3 executor Ljava/util/concurrent/Executor;
Signature: <V:Ljava/lang/Object;X:Ljava/lang/Throwable;>(Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;Ljava/lang/Class<TX;>;Lcom/google/common/base/Function<-TX;+TV;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
RuntimeInvisibleAnnotations:
com.google.common.util.concurrent.Partially$GwtIncompatible(value = "AVAILABLE but requires exceptionType to be Throwable.class")
MethodParameters:
Name Flags
input
exceptionType
fallback
executor
public static <V, X extends java.lang.Throwable> com.google.common.util.concurrent.ListenableFuture<V> catchingAsync(com.google.common.util.concurrent.ListenableFuture<? extends V>, java.lang.Class<X>, com.google.common.util.concurrent.AsyncFunction<? super X, ? extends V>);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Ljava/lang/Class;Lcom/google/common/util/concurrent/AsyncFunction;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
invokestatic com.google.common.util.concurrent.AbstractCatchingFuture.create:(Lcom/google/common/util/concurrent/ListenableFuture;Ljava/lang/Class;Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 input Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;
0 1 1 exceptionType Ljava/lang/Class<TX;>;
0 1 2 fallback Lcom/google/common/util/concurrent/AsyncFunction<-TX;+TV;>;
Signature: <V:Ljava/lang/Object;X:Ljava/lang/Throwable;>(Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;Ljava/lang/Class<TX;>;Lcom/google/common/util/concurrent/AsyncFunction<-TX;+TV;>;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
com.google.errorprone.annotations.DoNotCall()
com.google.common.util.concurrent.Partially$GwtIncompatible(value = "AVAILABLE but requires exceptionType to be Throwable.class")
MethodParameters:
Name Flags
input
exceptionType
fallback
public static <V, X extends java.lang.Throwable> com.google.common.util.concurrent.ListenableFuture<V> catchingAsync(com.google.common.util.concurrent.ListenableFuture<? extends V>, java.lang.Class<X>, com.google.common.util.concurrent.AsyncFunction<? super X, ? extends V>, java.util.concurrent.Executor);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Ljava/lang/Class;Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
invokestatic com.google.common.util.concurrent.AbstractCatchingFuture.create:(Lcom/google/common/util/concurrent/ListenableFuture;Ljava/lang/Class;Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 input Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;
0 1 1 exceptionType Ljava/lang/Class<TX;>;
0 1 2 fallback Lcom/google/common/util/concurrent/AsyncFunction<-TX;+TV;>;
0 1 3 executor Ljava/util/concurrent/Executor;
Signature: <V:Ljava/lang/Object;X:Ljava/lang/Throwable;>(Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;Ljava/lang/Class<TX;>;Lcom/google/common/util/concurrent/AsyncFunction<-TX;+TV;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
com.google.common.util.concurrent.Partially$GwtIncompatible(value = "AVAILABLE but requires exceptionType to be Throwable.class")
MethodParameters:
Name Flags
input
exceptionType
fallback
executor
public static <V> com.google.common.util.concurrent.ListenableFuture<V> withTimeout(com.google.common.util.concurrent.ListenableFuture<V>, long, java.util.concurrent.TimeUnit, java.util.concurrent.ScheduledExecutorService);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;JLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 0
lload 1
aload 3
aload 4
invokestatic com.google.common.util.concurrent.TimeoutFuture.create:(Lcom/google/common/util/concurrent/ListenableFuture;JLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 delegate Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
0 1 1 time J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
0 1 4 scheduledExecutor Ljava/util/concurrent/ScheduledExecutorService;
Signature: <V:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ListenableFuture<TV;>;JLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
delegate
time
unit
scheduledExecutor
public static <I, O> com.google.common.util.concurrent.ListenableFuture<O> transformAsync(com.google.common.util.concurrent.ListenableFuture<I>, com.google.common.util.concurrent.AsyncFunction<? super I, ? extends O>);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/AsyncFunction;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
invokestatic com.google.common.util.concurrent.AbstractTransformFuture.create:(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 input Lcom/google/common/util/concurrent/ListenableFuture<TI;>;
0 1 1 function Lcom/google/common/util/concurrent/AsyncFunction<-TI;+TO;>;
Signature: <I:Ljava/lang/Object;O:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ListenableFuture<TI;>;Lcom/google/common/util/concurrent/AsyncFunction<-TI;+TO;>;)Lcom/google/common/util/concurrent/ListenableFuture<TO;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.DoNotCall()
MethodParameters:
Name Flags
input
function
public static <I, O> com.google.common.util.concurrent.ListenableFuture<O> transformAsync(com.google.common.util.concurrent.ListenableFuture<I>, com.google.common.util.concurrent.AsyncFunction<? super I, ? extends O>, java.util.concurrent.Executor);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic com.google.common.util.concurrent.AbstractTransformFuture.create:(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 input Lcom/google/common/util/concurrent/ListenableFuture<TI;>;
0 1 1 function Lcom/google/common/util/concurrent/AsyncFunction<-TI;+TO;>;
0 1 2 executor Ljava/util/concurrent/Executor;
Signature: <I:Ljava/lang/Object;O:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ListenableFuture<TI;>;Lcom/google/common/util/concurrent/AsyncFunction<-TI;+TO;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture<TO;>;
MethodParameters:
Name Flags
input
function
executor
public static <I, O> com.google.common.util.concurrent.ListenableFuture<O> transform(com.google.common.util.concurrent.ListenableFuture<I>, com.google.common.base.Function<? super I, ? extends O>);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/base/Function;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
invokestatic com.google.common.util.concurrent.AbstractTransformFuture.create:(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 input Lcom/google/common/util/concurrent/ListenableFuture<TI;>;
0 1 1 function Lcom/google/common/base/Function<-TI;+TO;>;
Signature: <I:Ljava/lang/Object;O:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ListenableFuture<TI;>;Lcom/google/common/base/Function<-TI;+TO;>;)Lcom/google/common/util/concurrent/ListenableFuture<TO;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.DoNotCall()
MethodParameters:
Name Flags
input
function
public static <I, O> com.google.common.util.concurrent.ListenableFuture<O> transform(com.google.common.util.concurrent.ListenableFuture<I>, com.google.common.base.Function<? super I, ? extends O>, java.util.concurrent.Executor);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic com.google.common.util.concurrent.AbstractTransformFuture.create:(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 input Lcom/google/common/util/concurrent/ListenableFuture<TI;>;
0 1 1 function Lcom/google/common/base/Function<-TI;+TO;>;
0 1 2 executor Ljava/util/concurrent/Executor;
Signature: <I:Ljava/lang/Object;O:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ListenableFuture<TI;>;Lcom/google/common/base/Function<-TI;+TO;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture<TO;>;
MethodParameters:
Name Flags
input
function
executor
public static <I, O> java.util.concurrent.Future<O> lazyTransform(java.util.concurrent.Future<I>, com.google.common.base.Function<? super I, ? extends O>);
descriptor: (Ljava/util/concurrent/Future;Lcom/google/common/base/Function;)Ljava/util/concurrent/Future;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 1
invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: new com.google.common.util.concurrent.Futures$2
dup
aload 0
aload 1
invokespecial com.google.common.util.concurrent.Futures$2.<init>:(Ljava/util/concurrent/Future;Lcom/google/common/base/Function;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 input Ljava/util/concurrent/Future<TI;>;
0 3 1 function Lcom/google/common/base/Function<-TI;+TO;>;
Signature: <I:Ljava/lang/Object;O:Ljava/lang/Object;>(Ljava/util/concurrent/Future<TI;>;Lcom/google/common/base/Function<-TI;+TO;>;)Ljava/util/concurrent/Future<TO;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
input final
function final
public static <V> com.google.common.util.concurrent.ListenableFuture<java.util.List<V>> allAsList(com.google.common.util.concurrent.ListenableFuture<? extends V>[]);
descriptor: ([Lcom/google/common/util/concurrent/ListenableFuture;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=4, locals=1, args_size=1
start local 0 0: new com.google.common.util.concurrent.CollectionFuture$ListFuture
dup
aload 0
invokestatic com.google.common.collect.ImmutableList.copyOf:([Ljava/lang/Object;)Lcom/google/common/collect/ImmutableList;
iconst_1
invokespecial com.google.common.util.concurrent.CollectionFuture$ListFuture.<init>:(Lcom/google/common/collect/ImmutableCollection;Z)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures [Lcom/google/common/util/concurrent/ListenableFuture;
Signature: <V:Ljava/lang/Object;>([Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;)Lcom/google/common/util/concurrent/ListenableFuture<Ljava/util/List<TV;>;>;
RuntimeVisibleAnnotations:
java.lang.SafeVarargs()
RuntimeInvisibleAnnotations:
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
futures
public static <V> com.google.common.util.concurrent.ListenableFuture<java.util.List<V>> allAsList(java.lang.Iterable<? extends com.google.common.util.concurrent.ListenableFuture<? extends V>>);
descriptor: (Ljava/lang/Iterable;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new com.google.common.util.concurrent.CollectionFuture$ListFuture
dup
aload 0
invokestatic com.google.common.collect.ImmutableList.copyOf:(Ljava/lang/Iterable;)Lcom/google/common/collect/ImmutableList;
iconst_1
invokespecial com.google.common.util.concurrent.CollectionFuture$ListFuture.<init>:(Lcom/google/common/collect/ImmutableCollection;Z)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;>;
Signature: <V:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;>;)Lcom/google/common/util/concurrent/ListenableFuture<Ljava/util/List<TV;>;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
futures
public static <V> com.google.common.util.concurrent.Futures$FutureCombiner<V> whenAllComplete(com.google.common.util.concurrent.ListenableFuture<? extends V>[]);
descriptor: ([Lcom/google/common/util/concurrent/ListenableFuture;)Lcom/google/common/util/concurrent/Futures$FutureCombiner;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=4, locals=1, args_size=1
start local 0 0: new com.google.common.util.concurrent.Futures$FutureCombiner
dup
iconst_0
aload 0
invokestatic com.google.common.collect.ImmutableList.copyOf:([Ljava/lang/Object;)Lcom/google/common/collect/ImmutableList;
invokespecial com.google.common.util.concurrent.Futures$FutureCombiner.<init>:(ZLcom/google/common/collect/ImmutableList;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures [Lcom/google/common/util/concurrent/ListenableFuture;
Signature: <V:Ljava/lang/Object;>([Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;)Lcom/google/common/util/concurrent/Futures$FutureCombiner<TV;>;
RuntimeVisibleAnnotations:
java.lang.SafeVarargs()
MethodParameters:
Name Flags
futures
public static <V> com.google.common.util.concurrent.Futures$FutureCombiner<V> whenAllComplete(java.lang.Iterable<? extends com.google.common.util.concurrent.ListenableFuture<? extends V>>);
descriptor: (Ljava/lang/Iterable;)Lcom/google/common/util/concurrent/Futures$FutureCombiner;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new com.google.common.util.concurrent.Futures$FutureCombiner
dup
iconst_0
aload 0
invokestatic com.google.common.collect.ImmutableList.copyOf:(Ljava/lang/Iterable;)Lcom/google/common/collect/ImmutableList;
invokespecial com.google.common.util.concurrent.Futures$FutureCombiner.<init>:(ZLcom/google/common/collect/ImmutableList;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;>;
Signature: <V:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;>;)Lcom/google/common/util/concurrent/Futures$FutureCombiner<TV;>;
MethodParameters:
Name Flags
futures
public static <V> com.google.common.util.concurrent.Futures$FutureCombiner<V> whenAllSucceed(com.google.common.util.concurrent.ListenableFuture<? extends V>[]);
descriptor: ([Lcom/google/common/util/concurrent/ListenableFuture;)Lcom/google/common/util/concurrent/Futures$FutureCombiner;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=4, locals=1, args_size=1
start local 0 0: new com.google.common.util.concurrent.Futures$FutureCombiner
dup
iconst_1
aload 0
invokestatic com.google.common.collect.ImmutableList.copyOf:([Ljava/lang/Object;)Lcom/google/common/collect/ImmutableList;
invokespecial com.google.common.util.concurrent.Futures$FutureCombiner.<init>:(ZLcom/google/common/collect/ImmutableList;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures [Lcom/google/common/util/concurrent/ListenableFuture;
Signature: <V:Ljava/lang/Object;>([Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;)Lcom/google/common/util/concurrent/Futures$FutureCombiner<TV;>;
RuntimeVisibleAnnotations:
java.lang.SafeVarargs()
MethodParameters:
Name Flags
futures
public static <V> com.google.common.util.concurrent.Futures$FutureCombiner<V> whenAllSucceed(java.lang.Iterable<? extends com.google.common.util.concurrent.ListenableFuture<? extends V>>);
descriptor: (Ljava/lang/Iterable;)Lcom/google/common/util/concurrent/Futures$FutureCombiner;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new com.google.common.util.concurrent.Futures$FutureCombiner
dup
iconst_1
aload 0
invokestatic com.google.common.collect.ImmutableList.copyOf:(Ljava/lang/Iterable;)Lcom/google/common/collect/ImmutableList;
invokespecial com.google.common.util.concurrent.Futures$FutureCombiner.<init>:(ZLcom/google/common/collect/ImmutableList;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;>;
Signature: <V:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;>;)Lcom/google/common/util/concurrent/Futures$FutureCombiner<TV;>;
MethodParameters:
Name Flags
futures
public static <V> com.google.common.util.concurrent.ListenableFuture<V> nonCancellationPropagating(com.google.common.util.concurrent.ListenableFuture<V>);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
invokeinterface com.google.common.util.concurrent.ListenableFuture.isDone:()Z
ifeq 2
1: aload 0
areturn
2: StackMap locals:
StackMap stack:
new com.google.common.util.concurrent.Futures$NonCancellationPropagatingFuture
dup
aload 0
invokespecial com.google.common.util.concurrent.Futures$NonCancellationPropagatingFuture.<init>:(Lcom/google/common/util/concurrent/ListenableFuture;)V
astore 1
start local 1 3: aload 0
aload 1
invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
invokeinterface com.google.common.util.concurrent.ListenableFuture.addListener:(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
4: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 future Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
3 5 1 output Lcom/google/common/util/concurrent/Futures$NonCancellationPropagatingFuture<TV;>;
Signature: <V:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ListenableFuture<TV;>;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
MethodParameters:
Name Flags
future
public static <V> com.google.common.util.concurrent.ListenableFuture<java.util.List<V>> successfulAsList(com.google.common.util.concurrent.ListenableFuture<? extends V>[]);
descriptor: ([Lcom/google/common/util/concurrent/ListenableFuture;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=4, locals=1, args_size=1
start local 0 0: new com.google.common.util.concurrent.CollectionFuture$ListFuture
dup
aload 0
invokestatic com.google.common.collect.ImmutableList.copyOf:([Ljava/lang/Object;)Lcom/google/common/collect/ImmutableList;
iconst_0
invokespecial com.google.common.util.concurrent.CollectionFuture$ListFuture.<init>:(Lcom/google/common/collect/ImmutableCollection;Z)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures [Lcom/google/common/util/concurrent/ListenableFuture;
Signature: <V:Ljava/lang/Object;>([Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;)Lcom/google/common/util/concurrent/ListenableFuture<Ljava/util/List<TV;>;>;
RuntimeVisibleAnnotations:
java.lang.SafeVarargs()
RuntimeInvisibleAnnotations:
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
futures
public static <V> com.google.common.util.concurrent.ListenableFuture<java.util.List<V>> successfulAsList(java.lang.Iterable<? extends com.google.common.util.concurrent.ListenableFuture<? extends V>>);
descriptor: (Ljava/lang/Iterable;)Lcom/google/common/util/concurrent/ListenableFuture;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new com.google.common.util.concurrent.CollectionFuture$ListFuture
dup
aload 0
invokestatic com.google.common.collect.ImmutableList.copyOf:(Ljava/lang/Iterable;)Lcom/google/common/collect/ImmutableList;
iconst_0
invokespecial com.google.common.util.concurrent.CollectionFuture$ListFuture.<init>:(Lcom/google/common/collect/ImmutableCollection;Z)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;>;
Signature: <V:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TV;>;>;)Lcom/google/common/util/concurrent/ListenableFuture<Ljava/util/List<TV;>;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
futures
public static <T> com.google.common.collect.ImmutableList<com.google.common.util.concurrent.ListenableFuture<T>> inCompletionOrder(java.lang.Iterable<? extends com.google.common.util.concurrent.ListenableFuture<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Lcom/google/common/collect/ImmutableList;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=8, args_size=1
start local 0 0: aload 0
instanceof java.util.Collection
ifeq 3
1: aload 0
checkcast java.util.Collection
astore 1
start local 1 2: goto 4
end local 1 3: StackMap locals:
StackMap stack:
aload 0
invokestatic com.google.common.collect.ImmutableList.copyOf:(Ljava/lang/Iterable;)Lcom/google/common/collect/ImmutableList;
astore 1
start local 1 4: StackMap locals: java.util.Collection
StackMap stack:
aload 1
aload 1
invokeinterface java.util.Collection.size:()I
anewarray com.google.common.util.concurrent.ListenableFuture
invokeinterface java.util.Collection.toArray:([Ljava/lang/Object;)[Ljava/lang/Object;
checkcast com.google.common.util.concurrent.ListenableFuture[]
5: astore 2
start local 2 6: new com.google.common.util.concurrent.Futures$InCompletionOrderState
dup
aload 2
invokespecial com.google.common.util.concurrent.Futures$InCompletionOrderState.<init>:([Lcom/google/common/util/concurrent/ListenableFuture;)V
astore 3
start local 3 7: invokestatic com.google.common.collect.ImmutableList.builder:()Lcom/google/common/collect/ImmutableList$Builder;
astore 4
start local 4 8: iconst_0
istore 5
start local 5 9: goto 12
10: StackMap locals: java.lang.Iterable java.util.Collection com.google.common.util.concurrent.ListenableFuture[] com.google.common.util.concurrent.Futures$InCompletionOrderState com.google.common.collect.ImmutableList$Builder int
StackMap stack:
aload 4
new com.google.common.util.concurrent.Futures$InCompletionOrderFuture
dup
aload 3
invokespecial com.google.common.util.concurrent.Futures$InCompletionOrderFuture.<init>:(Lcom/google/common/util/concurrent/Futures$InCompletionOrderState;)V
invokevirtual com.google.common.collect.ImmutableList$Builder.add:(Ljava/lang/Object;)Lcom/google/common/collect/ImmutableList$Builder;
pop
11: iinc 5 1
StackMap locals:
StackMap stack:
12: iload 5
aload 2
arraylength
if_icmplt 10
end local 5 13: aload 4
invokevirtual com.google.common.collect.ImmutableList$Builder.build:()Lcom/google/common/collect/ImmutableList;
astore 5
start local 5 14: iconst_0
istore 6
start local 6 15: goto 22
16: StackMap locals: java.lang.Iterable java.util.Collection com.google.common.util.concurrent.ListenableFuture[] com.google.common.util.concurrent.Futures$InCompletionOrderState com.google.common.collect.ImmutableList$Builder com.google.common.collect.ImmutableList int
StackMap stack:
iload 6
istore 7
start local 7 17: aload 2
iload 6
aaload
18: new com.google.common.util.concurrent.Futures$3
dup
aload 3
aload 5
iload 7
invokespecial com.google.common.util.concurrent.Futures$3.<init>:(Lcom/google/common/util/concurrent/Futures$InCompletionOrderState;Lcom/google/common/collect/ImmutableList;I)V
19: invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
20: invokeinterface com.google.common.util.concurrent.ListenableFuture.addListener:(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
end local 7 21: iinc 6 1
StackMap locals:
StackMap stack:
22: iload 6
aload 2
arraylength
if_icmplt 16
end local 6 23: aload 5
astore 6
start local 6 24: aload 6
areturn
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 futures Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TT;>;>;
2 3 1 collection Ljava/util/Collection<Lcom/google/common/util/concurrent/ListenableFuture<+TT;>;>;
4 25 1 collection Ljava/util/Collection<Lcom/google/common/util/concurrent/ListenableFuture<+TT;>;>;
6 25 2 copy [Lcom/google/common/util/concurrent/ListenableFuture;
7 25 3 state Lcom/google/common/util/concurrent/Futures$InCompletionOrderState<TT;>;
8 25 4 delegatesBuilder Lcom/google/common/collect/ImmutableList$Builder<Lcom/google/common/util/concurrent/AbstractFuture<TT;>;>;
9 13 5 i I
14 25 5 delegates Lcom/google/common/collect/ImmutableList<Lcom/google/common/util/concurrent/AbstractFuture<TT;>;>;
15 23 6 i I
17 21 7 localI I
24 25 6 delegatesCast Lcom/google/common/collect/ImmutableList<Lcom/google/common/util/concurrent/ListenableFuture<TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ListenableFuture<+TT;>;>;)Lcom/google/common/collect/ImmutableList<Lcom/google/common/util/concurrent/ListenableFuture<TT;>;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
futures
public static <V> void addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/FutureCallback;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.MoreExecutors.directExecutor:()Ljava/util/concurrent/Executor;
invokestatic com.google.common.util.concurrent.Futures.addCallback:(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/FutureCallback;Ljava/util/concurrent/Executor;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 future Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
0 2 1 callback Lcom/google/common/util/concurrent/FutureCallback<-TV;>;
Signature: <V:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ListenableFuture<TV;>;Lcom/google/common/util/concurrent/FutureCallback<-TV;>;)V
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.DoNotCall()
MethodParameters:
Name Flags
future
callback
public static <V> void addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor);
descriptor: (Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/FutureCallback;Ljava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
new com.google.common.util.concurrent.Futures$CallbackListener
dup
aload 0
aload 1
invokespecial com.google.common.util.concurrent.Futures$CallbackListener.<init>:(Ljava/util/concurrent/Future;Lcom/google/common/util/concurrent/FutureCallback;)V
aload 2
invokeinterface com.google.common.util.concurrent.ListenableFuture.addListener:(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 future Lcom/google/common/util/concurrent/ListenableFuture<TV;>;
0 3 1 callback Lcom/google/common/util/concurrent/FutureCallback<-TV;>;
0 3 2 executor Ljava/util/concurrent/Executor;
Signature: <V:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ListenableFuture<TV;>;Lcom/google/common/util/concurrent/FutureCallback<-TV;>;Ljava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
future final
callback final
executor
public static <V> V getDone(java.util.concurrent.Future<V>);
descriptor: (Ljava/util/concurrent/Future;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface java.util.concurrent.Future.isDone:()Z
ldc "Future was expected to be done: %s"
aload 0
invokestatic com.google.common.base.Preconditions.checkState:(ZLjava/lang/String;Ljava/lang/Object;)V
1: aload 0
invokestatic com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly:(Ljava/util/concurrent/Future;)Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 future Ljava/util/concurrent/Future<TV;>;
Exceptions:
throws java.util.concurrent.ExecutionException
Signature: <V:Ljava/lang/Object;>(Ljava/util/concurrent/Future<TV;>;)TV;
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
MethodParameters:
Name Flags
future
public static <V, X extends java.lang.Exception> V getChecked(java.util.concurrent.Future<V>, java.lang.Class<X>) throws X;
descriptor: (Ljava/util/concurrent/Future;Ljava/lang/Class;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.FuturesGetChecked.getChecked:(Ljava/util/concurrent/Future;Ljava/lang/Class;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 future Ljava/util/concurrent/Future<TV;>;
0 1 1 exceptionClass Ljava/lang/Class<TX;>;
Exceptions:
throws java.lang.Exception
Signature: <V:Ljava/lang/Object;X:Ljava/lang/Exception;>(Ljava/util/concurrent/Future<TV;>;Ljava/lang/Class<TX;>;)TV;^TX;
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
future
exceptionClass
public static <V, X extends java.lang.Exception> V getChecked(java.util.concurrent.Future<V>, java.lang.Class<X>, long, java.util.concurrent.TimeUnit) throws X;
descriptor: (Ljava/util/concurrent/Future;Ljava/lang/Class;JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
aload 1
lload 2
aload 4
invokestatic com.google.common.util.concurrent.FuturesGetChecked.getChecked:(Ljava/util/concurrent/Future;Ljava/lang/Class;JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
areturn
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 future Ljava/util/concurrent/Future<TV;>;
0 1 1 exceptionClass Ljava/lang/Class<TX;>;
0 1 2 timeout J
0 1 4 unit Ljava/util/concurrent/TimeUnit;
Exceptions:
throws java.lang.Exception
Signature: <V:Ljava/lang/Object;X:Ljava/lang/Exception;>(Ljava/util/concurrent/Future<TV;>;Ljava/lang/Class<TX;>;JLjava/util/concurrent/TimeUnit;)TV;^TX;
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
future
exceptionClass
timeout
unit
public static <V> V getUnchecked(java.util.concurrent.Future<V>);
descriptor: (Ljava/util/concurrent/Future;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
invokestatic com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly:(Ljava/util/concurrent/Future;)Ljava/lang/Object;
2: areturn
3: StackMap locals:
StackMap stack: java.util.concurrent.ExecutionException
astore 1
start local 1 4: aload 1
invokevirtual java.util.concurrent.ExecutionException.getCause:()Ljava/lang/Throwable;
invokestatic com.google.common.util.concurrent.Futures.wrapAndThrowUnchecked:(Ljava/lang/Throwable;)V
5: new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 future Ljava/util/concurrent/Future<TV;>;
4 6 1 e Ljava/util/concurrent/ExecutionException;
Exception table:
from to target type
1 2 3 Class java.util.concurrent.ExecutionException
Signature: <V:Ljava/lang/Object;>(Ljava/util/concurrent/Future<TV;>;)TV;
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
MethodParameters:
Name Flags
future
private static void wrapAndThrowUnchecked(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
instanceof java.lang.Error
ifeq 2
1: new com.google.common.util.concurrent.ExecutionError
dup
aload 0
checkcast java.lang.Error
invokespecial com.google.common.util.concurrent.ExecutionError.<init>:(Ljava/lang/Error;)V
athrow
2: StackMap locals:
StackMap stack:
new com.google.common.util.concurrent.UncheckedExecutionException
dup
aload 0
invokespecial com.google.common.util.concurrent.UncheckedExecutionException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 cause Ljava/lang/Throwable;
MethodParameters:
Name Flags
cause
}
SourceFile: "Futures.java"
NestMembers:
com.google.common.util.concurrent.Futures$1 com.google.common.util.concurrent.Futures$2 com.google.common.util.concurrent.Futures$3 com.google.common.util.concurrent.Futures$CallbackListener com.google.common.util.concurrent.Futures$FutureCombiner com.google.common.util.concurrent.Futures$FutureCombiner$1 com.google.common.util.concurrent.Futures$InCompletionOrderFuture com.google.common.util.concurrent.Futures$InCompletionOrderState com.google.common.util.concurrent.Futures$MappingCheckedFuture com.google.common.util.concurrent.Futures$NonCancellationPropagatingFuture
InnerClasses:
public final Builder = com.google.common.collect.ImmutableList$Builder of com.google.common.collect.ImmutableList
final ListFuture = com.google.common.util.concurrent.CollectionFuture$ListFuture of com.google.common.util.concurrent.CollectionFuture
com.google.common.util.concurrent.Futures$1
com.google.common.util.concurrent.Futures$2
com.google.common.util.concurrent.Futures$3
private final CallbackListener = com.google.common.util.concurrent.Futures$CallbackListener of com.google.common.util.concurrent.Futures
public final FutureCombiner = com.google.common.util.concurrent.Futures$FutureCombiner of com.google.common.util.concurrent.Futures
private final InCompletionOrderFuture = com.google.common.util.concurrent.Futures$InCompletionOrderFuture of com.google.common.util.concurrent.Futures
private final InCompletionOrderState = com.google.common.util.concurrent.Futures$InCompletionOrderState of com.google.common.util.concurrent.Futures
private MappingCheckedFuture = com.google.common.util.concurrent.Futures$MappingCheckedFuture of com.google.common.util.concurrent.Futures
private final NonCancellationPropagatingFuture = com.google.common.util.concurrent.Futures$NonCancellationPropagatingFuture of com.google.common.util.concurrent.Futures
final ImmediateCancelledFuture = com.google.common.util.concurrent.ImmediateFuture$ImmediateCancelledFuture of com.google.common.util.concurrent.ImmediateFuture
ImmediateFailedCheckedFuture = com.google.common.util.concurrent.ImmediateFuture$ImmediateFailedCheckedFuture of com.google.common.util.concurrent.ImmediateFuture
final ImmediateFailedFuture = com.google.common.util.concurrent.ImmediateFuture$ImmediateFailedFuture of com.google.common.util.concurrent.ImmediateFuture
ImmediateSuccessfulCheckedFuture = com.google.common.util.concurrent.ImmediateFuture$ImmediateSuccessfulCheckedFuture of com.google.common.util.concurrent.ImmediateFuture
ImmediateSuccessfulFuture = com.google.common.util.concurrent.ImmediateFuture$ImmediateSuccessfulFuture of com.google.common.util.concurrent.ImmediateFuture
abstract GwtIncompatible = com.google.common.util.concurrent.Partially$GwtIncompatible of com.google.common.util.concurrent.Partially
RuntimeInvisibleAnnotations:
com.google.common.annotations.Beta()
com.google.common.annotations.GwtCompatible(emulated = true)