Repository URL to install this package:
|
Version:
0.6.14 ▾
|
com.supertenant/supermeter
/
agent
/
com
/
google
/
common
/
util
/
concurrent
/
ClosingFuture.stclazz
|
|---|
Êþº¾ 4V
j
k
l
m
n
o
p
q
rs
t
u
vw
xyz
{
|}
x~
t L
#
'
*
.
¡
¢£
¤¥
3¦
§
¨©
7ª«
9¬
®
<¦
¯
°±
@ª L²
³ ´µ¶
·¸¹
Gº
» }¼
#½¾
L¿ÀÁ
NÂÃÄÅ
S LÆÇÈÉ
SÊ
ZËÌ
\º ÍÎ
ÏÐ
'q LÑ
'Ò
ÓÔ
ÕÖ
Õ×
ÕØ
LÙ ´ÚÛ
ÜÝ
nÞß ´à
·áâã
äå
·æç
vè
#é
'ê
ëì
·íî InnerClasses State
CloseableList Combiner5 Combiner4 Combiner3 Combiner2 Combinerï Peekerð ValueAndCloserConsumer ValueAndCloserñ AsyncClosingFunctionò ClosingFunctionó AsyncClosingCallableô ClosingCallableõ DeferredCloser logger Ljava/util/logging/Logger; state -Ljava/util/concurrent/atomic/AtomicReference; Signature fLjava/util/concurrent/atomic/AtomicReference<Lcom/google/common/util/concurrent/ClosingFuture$State;>;
closeables ?Lcom/google/common/util/concurrent/ClosingFuture$CloseableList; future 0Lcom/google/common/util/concurrent/FluentFuture; 5Lcom/google/common/util/concurrent/FluentFuture<TV;>; submit (Lcom/google/common/util/concurrent/ClosingFuture$ClosingCallable;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture; Code LineNumberTable LocalVariableTable callable ALcom/google/common/util/concurrent/ClosingFuture$ClosingCallable; executor Ljava/util/concurrent/Executor; LocalVariableTypeTable FLcom/google/common/util/concurrent/ClosingFuture$ClosingCallable<TV;>; ³<V:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ClosingFuture$ClosingCallable<TV;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture<TV;>; RuntimeVisibleTypeAnnotations 5Lorg/checkerframework/checker/nullness/qual/Nullable; submitAsync (Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingCallable;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture; FLcom/google/common/util/concurrent/ClosingFuture$AsyncClosingCallable; KLcom/google/common/util/concurrent/ClosingFuture$AsyncClosingCallable<TV;>; ¸<V:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingCallable<TV;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture<TV;>; from g(Lcom/google/common/util/concurrent/ListenableFuture;)Lcom/google/common/util/concurrent/ClosingFuture; 4Lcom/google/common/util/concurrent/ListenableFuture; 9Lcom/google/common/util/concurrent/ListenableFuture<TV;>; <V:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ListenableFuture<TV;>;)Lcom/google/common/util/concurrent/ClosingFuture<TV;>; eventuallyClosing (Lcom/google/common/util/concurrent/ListenableFuture;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture; closingExecutor
closingFuture 1Lcom/google/common/util/concurrent/ClosingFuture; 9Lcom/google/common/util/concurrent/ListenableFuture<TC;>; 6Lcom/google/common/util/concurrent/ClosingFuture<TC;>;
Deprecated À<C:Ljava/lang/Object;:Ljava/lang/AutoCloseable;>(Lcom/google/common/util/concurrent/ListenableFuture<TC;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture<TC;>; RuntimeVisibleAnnotations Ljava/lang/Deprecated; whenAllComplete P(Ljava/lang/Iterable;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner; futures Ljava/lang/Iterable; KLjava/lang/Iterable<+Lcom/google/common/util/concurrent/ClosingFuture<*>;>; (Ljava/lang/Iterable<+Lcom/google/common/util/concurrent/ClosingFuture<*>;>;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner; (Lcom/google/common/util/concurrent/ClosingFuture;[Lcom/google/common/util/concurrent/ClosingFuture;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner; future1 moreFutures 2[Lcom/google/common/util/concurrent/ClosingFuture; 4Lcom/google/common/util/concurrent/ClosingFuture<*>; 5[Lcom/google/common/util/concurrent/ClosingFuture<*>; ¥(Lcom/google/common/util/concurrent/ClosingFuture<*>;[Lcom/google/common/util/concurrent/ClosingFuture<*>;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner; whenAllSucceed (Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner2; future2 7Lcom/google/common/util/concurrent/ClosingFuture<TV1;>; 7Lcom/google/common/util/concurrent/ClosingFuture<TV2;>; á<V1:Ljava/lang/Object;V2:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ClosingFuture<TV1;>;Lcom/google/common/util/concurrent/ClosingFuture<TV2;>;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner2<TV1;TV2;>; Ð(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner3; future3 7Lcom/google/common/util/concurrent/ClosingFuture<TV3;>;1<V1:Ljava/lang/Object;V2:Ljava/lang/Object;V3:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ClosingFuture<TV1;>;Lcom/google/common/util/concurrent/ClosingFuture<TV2;>;Lcom/google/common/util/concurrent/ClosingFuture<TV3;>;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner3<TV1;TV2;TV3;>;(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner4; future4 7Lcom/google/common/util/concurrent/ClosingFuture<TV4;>;<V1:Ljava/lang/Object;V2:Ljava/lang/Object;V3:Ljava/lang/Object;V4:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ClosingFuture<TV1;>;Lcom/google/common/util/concurrent/ClosingFuture<TV2;>;Lcom/google/common/util/concurrent/ClosingFuture<TV3;>;Lcom/google/common/util/concurrent/ClosingFuture<TV4;>;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner4<TV1;TV2;TV3;TV4;>;2(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner5; future5 7Lcom/google/common/util/concurrent/ClosingFuture<TV5;>;Ñ<V1:Ljava/lang/Object;V2:Ljava/lang/Object;V3:Ljava/lang/Object;V4:Ljava/lang/Object;V5:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ClosingFuture<TV1;>;Lcom/google/common/util/concurrent/ClosingFuture<TV2;>;Lcom/google/common/util/concurrent/ClosingFuture<TV3;>;Lcom/google/common/util/concurrent/ClosingFuture<TV4;>;Lcom/google/common/util/concurrent/ClosingFuture<TV5;>;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner5<TV1;TV2;TV3;TV4;TV5;>;(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;[Lcom/google/common/util/concurrent/ClosingFuture;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner; future6©(Lcom/google/common/util/concurrent/ClosingFuture<*>;Lcom/google/common/util/concurrent/ClosingFuture<*>;Lcom/google/common/util/concurrent/ClosingFuture<*>;Lcom/google/common/util/concurrent/ClosingFuture<*>;Lcom/google/common/util/concurrent/ClosingFuture<*>;Lcom/google/common/util/concurrent/ClosingFuture<*>;[Lcom/google/common/util/concurrent/ClosingFuture<*>;)Lcom/google/common/util/concurrent/ClosingFuture$Combiner; <init> 7(Lcom/google/common/util/concurrent/ListenableFuture;)V this 6Lcom/google/common/util/concurrent/ClosingFuture<TV;>; <(Lcom/google/common/util/concurrent/ListenableFuture<TV;>;)V c(Lcom/google/common/util/concurrent/ClosingFuture$ClosingCallable;Ljava/util/concurrent/Executor;)V task ?Lcom/google/common/util/concurrent/TrustedListenableFutureTask; DLcom/google/common/util/concurrent/TrustedListenableFutureTask<TV;>; h(Lcom/google/common/util/concurrent/ClosingFuture$ClosingCallable<TV;>;Ljava/util/concurrent/Executor;)V h(Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingCallable;Ljava/util/concurrent/Executor;)V m(Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingCallable<TV;>;Ljava/util/concurrent/Executor;)V statusFuture 6()Lcom/google/common/util/concurrent/ListenableFuture; 9()Lcom/google/common/util/concurrent/ListenableFuture<*>; transform (Lcom/google/common/util/concurrent/ClosingFuture$ClosingFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture; function ALcom/google/common/util/concurrent/ClosingFuture$ClosingFunction;
applyFunction 1Lcom/google/common/util/concurrent/AsyncFunction; JLcom/google/common/util/concurrent/ClosingFuture$ClosingFunction<-TV;TU;>; 9Lcom/google/common/util/concurrent/AsyncFunction<TV;TU;>; ·<U:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ClosingFuture$ClosingFunction<-TV;TU;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture<TU;>; transformAsync (Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture; FLcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction; OLcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction<-TV;TU;>; ¼<U:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction<-TV;TU;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture<TU;>;
withoutCloser y(Lcom/google/common/util/concurrent/AsyncFunction;)Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction; ³<V:Ljava/lang/Object;U:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/AsyncFunction<TV;TU;>;)Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction<TV;TU;>; catching ¤(Ljava/lang/Class;Lcom/google/common/util/concurrent/ClosingFuture$ClosingFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture;
exceptionType Ljava/lang/Class; fallback Ljava/lang/Class<TX;>; KLcom/google/common/util/concurrent/ClosingFuture$ClosingFunction<-TX;+TV;>; Ñ<X:Ljava/lang/Throwable;>(Ljava/lang/Class<TX;>;Lcom/google/common/util/concurrent/ClosingFuture$ClosingFunction<-TX;+TV;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture<TV;>; catchingMoreGeneric
applyFallback JLcom/google/common/util/concurrent/ClosingFuture$ClosingFunction<-TX;TW;>; 9Lcom/google/common/util/concurrent/AsyncFunction<TX;TW;>; Õ<X:Ljava/lang/Throwable;W:TV;>(Ljava/lang/Class<TX;>;Lcom/google/common/util/concurrent/ClosingFuture$ClosingFunction<-TX;TW;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture<TV;>;
catchingAsync ©(Ljava/lang/Class;Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture; PLcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction<-TX;+TV;>; Ö<X:Ljava/lang/Throwable;>(Ljava/lang/Class<TX;>;Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction<-TX;+TV;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture<TV;>; catchingAsyncMoreGeneric
asyncFunction OLcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction<-TX;TW;>; Ú<X:Ljava/lang/Throwable;W:TV;>(Ljava/lang/Class<TX;>;Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction<-TX;TW;>;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ClosingFuture<TV;>; finishToFuture 2()Lcom/google/common/util/concurrent/FluentFuture;
StackMapTable 7()Lcom/google/common/util/concurrent/FluentFuture<TV;>; finishToValueAndCloser j(Lcom/google/common/util/concurrent/ClosingFuture$ValueAndCloserConsumer;Ljava/util/concurrent/Executor;)V consumer HLcom/google/common/util/concurrent/ClosingFuture$ValueAndCloserConsumer; NLcom/google/common/util/concurrent/ClosingFuture$ValueAndCloserConsumer<-TV;>; p(Lcom/google/common/util/concurrent/ClosingFuture$ValueAndCloserConsumer<-TV;>;Ljava/util/concurrent/Executor;)V provideValueAndCloser |(Lcom/google/common/util/concurrent/ClosingFuture$ValueAndCloserConsumer;Lcom/google/common/util/concurrent/ClosingFuture;)V MLcom/google/common/util/concurrent/ClosingFuture$ValueAndCloserConsumer<TC;>; ¡<C:Ljava/lang/Object;V:TC;>(Lcom/google/common/util/concurrent/ClosingFuture$ValueAndCloserConsumer<TC;>;Lcom/google/common/util/concurrent/ClosingFuture<TV;>;)V cancel (Z)Z mayInterruptIfRunning Z cancelled RuntimeInvisibleAnnotations 8Lcom/google/errorprone/annotations/CanIgnoreReturnValue; close ()V derive c(Lcom/google/common/util/concurrent/FluentFuture;)Lcom/google/common/util/concurrent/ClosingFuture; derived 5Lcom/google/common/util/concurrent/FluentFuture<TU;>; 6Lcom/google/common/util/concurrent/ClosingFuture<TU;>; <U:Ljava/lang/Object;>(Lcom/google/common/util/concurrent/FluentFuture<TU;>;)Lcom/google/common/util/concurrent/ClosingFuture<TU;>; becomeSubsumedInto B(Lcom/google/common/util/concurrent/ClosingFuture$CloseableList;)V otherCloseables toString ()Ljava/lang/String; finalize closeQuietly ;(Ljava/lang/AutoCloseable;Ljava/util/concurrent/Executor;)V e 1Ljava/util/concurrent/RejectedExecutionException; closeable Ljava/lang/AutoCloseable; "RuntimeVisibleParameterAnnotations Ljavax/annotation/CheckForNull; checkAndUpdateState q(Lcom/google/common/util/concurrent/ClosingFuture$State;Lcom/google/common/util/concurrent/ClosingFuture$State;)V oldState 7Lcom/google/common/util/concurrent/ClosingFuture$State; newState compareAndUpdateState q(Lcom/google/common/util/concurrent/ClosingFuture$State;Lcom/google/common/util/concurrent/ClosingFuture$State;)Z whenClosedCountDown '()Ljava/util/concurrent/CountDownLatch; 1Lcom/google/common/annotations/VisibleForTesting;
access$000 c(Lcom/google/common/util/concurrent/ClosingFuture;)Lcom/google/common/util/concurrent/FluentFuture; x0
access$100 4(Lcom/google/common/util/concurrent/ClosingFuture;)V
access$200 r(Lcom/google/common/util/concurrent/ClosingFuture;)Lcom/google/common/util/concurrent/ClosingFuture$CloseableList; access$1000 s(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$CloseableList;)V x1 access$1100 ¢(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$State;Lcom/google/common/util/concurrent/ClosingFuture$State;)V x2 access$1200 j(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/ClosingFuture$1;)V 3Lcom/google/common/util/concurrent/ClosingFuture$1; access$3200 ()Ljava/util/logging/Logger; access$3300 <clinit> (<V:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile ClosingFuture.java -Lcom/google/errorprone/annotations/DoNotMock; value 0Use ClosingFuture.from(Futures.immediate*Future) CLcom/google/common/util/concurrent/ElementTypesAreNonnullByDefault;=> å æ$%EF78 /0 /com/google/common/util/concurrent/ClosingFuture å ê å ïö÷øùúû 1com/google/common/util/concurrent/ClosingFuture$1 åüýþÿ 8com/google/common/util/concurrent/ClosingFuture$Combiner å Ã Ä 9com/google/common/util/concurrent/ClosingFuture$Combiner2 å 9com/google/common/util/concurrent/ClosingFuture$Combiner3 å 9com/google/common/util/concurrent/ClosingFuture$Combiner4 å 9com/google/common/util/concurrent/ClosingFuture$Combiner5 å
Ð Ä å0 +java/util/concurrent/atomic/AtomicReferenceH å =com/google/common/util/concurrent/ClosingFuture$CloseableList å ³ 1com/google/common/util/concurrent/ClosingFuture$2 å 1com/google/common/util/concurrent/ClosingFuture$3 å ô 1com/google/common/util/concurrent/ClosingFuture$4 å! ý"12 1com/google/common/util/concurrent/ClosingFuture$5 å# 1com/google/common/util/concurrent/ClosingFuture$6 å$
1com/google/common/util/concurrent/ClosingFuture$7% 1com/google/common/util/concurrent/ClosingFuture$8&HJK'() will close {0}*+, 1com/google/common/util/concurrent/ClosingFuture$9 åS-./012 5com/google/common/util/concurrent/ClosingFuture$State34 java/lang/IllegalStateException 8Cannot call finishToFuture() after deriving another step å5 CCannot call finishToFuture() after calling finishToValueAndCloser() "Cannot call finishToFuture() twice java/lang/AssertionError6H @Cannot call finishToValueAndCloser() after deriving another step CCannot call finishToValueAndCloser() after calling finishToFuture() *Cannot call finishToValueAndCloser() twice 2com/google/common/util/concurrent/ClosingFuture$10 å7 >com/google/common/util/concurrent/ClosingFuture$ValueAndCloser89 cancelling {0}() closing {0}:H;><=?@;AB?:;CDE) ;Uh oh! An open ClosingFuture has leaked and will close: {0} 2com/google/common/util/concurrent/ClosingFuture$11 åF /java/util/concurrent/RejectedExecutionExceptionG)HI /while submitting close to %s; will close inline java/lang/ObjectJKL+M &Expected state to be %s, but it was %sNOPQLMRS;TU 2com/google/common/util/concurrent/ClosingFuture$12 6com/google/common/util/concurrent/ClosingFuture$Peeker Fcom/google/common/util/concurrent/ClosingFuture$ValueAndCloserConsumer Dcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction ?com/google/common/util/concurrent/ClosingFuture$ClosingFunction Dcom/google/common/util/concurrent/ClosingFuture$AsyncClosingCallable ?com/google/common/util/concurrent/ClosingFuture$ClosingCallable >com/google/common/util/concurrent/ClosingFuture$DeferredCloser $com/google/common/base/Preconditions checkNotNull &(Ljava/lang/Object;)Ljava/lang/Object; )com/google/common/util/concurrent/Futures nonCancellationPropagating j(Lcom/google/common/util/concurrent/ListenableFuture;)Lcom/google/common/util/concurrent/ListenableFuture; S(Lcom/google/common/util/concurrent/ClosingFuture;Ljava/util/concurrent/Executor;)V /com/google/common/util/concurrent/MoreExecutors directExecutor !()Ljava/util/concurrent/Executor; addCallback (Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/FutureCallback;Ljava/util/concurrent/Executor;)V K(ZLjava/lang/Iterable;Lcom/google/common/util/concurrent/ClosingFuture$1;)V com/google/common/collect/Lists asList 7(Ljava/lang/Object;[Ljava/lang/Object;)Ljava/util/List; (Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$1;)V É(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$1;)V ú(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$1;)V+(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$1;)V (com/google/common/collect/FluentIterable of Q(Ljava/lang/Object;[Ljava/lang/Object;)Lcom/google/common/collect/FluentIterable; append ?([Ljava/lang/Object;)Lcom/google/common/collect/FluentIterable; OPEN (Ljava/lang/Object;)V 6(Lcom/google/common/util/concurrent/ClosingFuture$1;)V .com/google/common/util/concurrent/FluentFuture f(Lcom/google/common/util/concurrent/ListenableFuture;)Lcom/google/common/util/concurrent/FluentFuture; u(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$ClosingCallable;)V =com/google/common/util/concurrent/TrustedListenableFutureTask create `(Ljava/util/concurrent/Callable;)Lcom/google/common/util/concurrent/TrustedListenableFutureTask; java/util/concurrent/Executor execute (Ljava/lang/Runnable;)V z(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingCallable;)V r(Lcom/google/common/util/concurrent/AsyncCallable;)Lcom/google/common/util/concurrent/TrustedListenableFutureTask; com/google/common/base/Functions constant 5(Ljava/lang/Object;)Lcom/google/common/base/Function; r(Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/FluentFuture; u(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$ClosingFunction;)V (Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/FluentFuture; z(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$AsyncClosingFunction;)V 4(Lcom/google/common/util/concurrent/AsyncFunction;)V (Ljava/lang/Class;Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/FluentFuture;
WILL_CLOSE java/util/logging/Level FINER Ljava/util/logging/Level; java/util/logging/Logger log @(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V addListener 6(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V @$SwitchMap$com$google$common$util$concurrent$ClosingFuture$State [I get ()Ljava/lang/Object; ordinal ()I (Ljava/lang/String;)V WILL_CREATE_VALUE_AND_CLOSER |(Lcom/google/common/util/concurrent/ClosingFuture;Lcom/google/common/util/concurrent/ClosingFuture$ValueAndCloserConsumer;)V accept C(Lcom/google/common/util/concurrent/ClosingFuture$ValueAndCloser;)V SUBSUMED add "com/google/common/base/MoreObjects toStringHelper ToStringHelper G(Ljava/lang/Object;)Lcom/google/common/base/MoreObjects$ToStringHelper; 1com/google/common/base/MoreObjects$ToStringHelper Y(Ljava/lang/String;Ljava/lang/Object;)Lcom/google/common/base/MoreObjects$ToStringHelper; addValue equals (Ljava/lang/Object;)Z SEVERE (Ljava/lang/AutoCloseable;)V WARNING
isLoggable (Ljava/util/logging/Level;)Z java/lang/String format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
checkState :(ZLjava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
compareAndSet '(Ljava/lang/Object;Ljava/lang/Object;)Z java/lang/Class getName getLogger .(Ljava/lang/String;)Ljava/util/logging/Logger; 1
t . ¡ ¢ P
»
Y*+· ° £
¤
¥ ¦
§ ¨ ©
¥ ª « ¬
® ¯ ¢ P
»
Y*+· ° £ ¤
¥ °
§ ¨ ©
¥ ± ² ¬
³ ´ ¢ E »
Y*· ° £ ¤ µ © ¶ · ¬
¸ ¹ ¢ #+¸
W»
Y*¸ · M*» Y,+· ¸ ¸ ,° £ ¸ ¹ º Å º !Æ ¤ # µ # º ¨ » ¼ © # ½ » ¾ ¿ À Á Â ¬ Ã Ä ¢ G » Y*· ° £ Ð ¤ Å Æ © Å Ç È Ã É ¢ Y *+¸ ¸ ° £ Û ¤ Ê ¼ Ë Ì © Ê Í Ë Î Ï Ð Ä ¢ G » Y*· ° £ æ ¤ Å Æ © Å Ç È Ð Ñ ¢ [ » Y*+· ° £ õ ¤ Ê ¼ Ò ¼ © Ê Ó Ò Ô Õ ¬ Ð Ö ¢ p » Y*+,· ° £ ¤ Ê ¼ Ò ¼ × ¼ © Ê Ó Ò Ô × Ø Ù ¬ Ð Ú ¢
» Y*+,-· ° £ ¤ *
Ê ¼
Ò ¼
× ¼
Û ¼ © *
Ê Ó
Ò Ô
× Ø
Û Ü Ý ¬ " Ð Þ ¢ » Y*+,-· ° £ 6 ¤ 4 Ê ¼ Ò ¼ × ¼ Û ¼ ß ¼ © 4 Ê Ó Ò Ô × Ø Û Ü ß à á ¬ * Ð â ¢ ç '*½
Y+SY,SY-SYSYS¸ ¶ ¸ !° £ H I J #H ¤ H ' Ê ¼ ' Ò ¼ ' × ¼ ' Û ¼ ' ß ¼ ' ã ¼ ' Ë Ì © H ' Ê Í ' Ò Í ' × Í ' Û Í ' ß Í ' ã Í ' Ë Î ä å æ ¢ '*· "*» #Y² $· %µ &*» 'Y· (µ *+¸ )µ ± £ Q M N R &S ¤ ' ç ¼ ' µ © ' ç è ' ¶ é å ê ¢ Ë =*· "*» #Y² $· %µ &*» 'Y· (µ +¸
W» *Y*+· +¸ ,N,-¹ - *-µ ± £ &