2?0org/elasticsearch/common/util/concurrent/Futuresjava/lang/Object Futures.java+Lorg/elasticsearch/common/annotations/Beta;Eorg/elasticsearch/common/util/concurrent/Futures$MappingCheckedFutureMappingCheckedFuture?org/elasticsearch/common/util/concurrent/Futures$CombinedFuture CombinedFuture?org/elasticsearch/common/util/concurrent/Futures$FutureCombiner FutureCombinerQorg/elasticsearch/common/util/concurrent/Futures$NonCancellationPropagatingFuture NonCancellationPropagatingFuture?org/elasticsearch/common/util/concurrent/Futures$CombinerFutureCombinerFuture@org/elasticsearch/common/util/concurrent/Futures$WrappedCombinerWrappedCombinerIorg/elasticsearch/common/util/concurrent/Futures$ChainingListenableFutureChainingListenableFuture?org/elasticsearch/common/util/concurrent/Futures$FallbackFutureFallbackFutureMorg/elasticsearch/common/util/concurrent/Futures$ImmediateFailedCheckedFutureImmediateFailedCheckedFutureIorg/elasticsearch/common/util/concurrent/Futures$ImmediateCancelledFuture"ImmediateCancelledFutureForg/elasticsearch/common/util/concurrent/Futures$ImmediateFailedFuture%ImmediateFailedFutureQorg/elasticsearch/common/util/concurrent/Futures$ImmediateSuccessfulCheckedFuture( ImmediateSuccessfulCheckedFutureJorg/elasticsearch/common/util/concurrent/Futures$ImmediateSuccessfulFuture+ImmediateSuccessfulFuture@org/elasticsearch/common/util/concurrent/Futures$ImmediateFuture.ImmediateFuture2org/elasticsearch/common/util/concurrent/Futures$812org/elasticsearch/common/util/concurrent/Futures$732org/elasticsearch/common/util/concurrent/Futures$652org/elasticsearch/common/util/concurrent/Futures$572org/elasticsearch/common/util/concurrent/Futures$492org/elasticsearch/common/util/concurrent/Futures$3;2org/elasticsearch/common/util/concurrent/Futures$2=2org/elasticsearch/common/util/concurrent/Futures$1?6org/elasticsearch/common/collect/ImmutableList$BuilderA.org/elasticsearch/common/collect/ImmutableListCBuilder DEREFERENCER8Lorg/elasticsearch/common/util/concurrent/AsyncFunction;Lorg/elasticsearch/common/util/concurrent/AsyncFunction;Ljava/lang/Object;>;WITH_STRING_PARAM_FIRST+Lorg/elasticsearch/common/collect/Ordering;OLorg/elasticsearch/common/collect/Ordering;>;()V LM Nthis2Lorg/elasticsearch/common/util/concurrent/Futures; makeChecked(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/base/Function;)Lorg/elasticsearch/common/util/concurrent/CheckedFuture;+org/elasticsearch/common/base/PreconditionsT checkNotNull&(Ljava/lang/Object;)Ljava/lang/Object; VW UX9org/elasticsearch/common/util/concurrent/ListenableFutureZf(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/base/Function;)V L\ ]future@Lorg/elasticsearch/common/util/concurrent/ListenableFuture;;Lorg/elasticsearch/common/util/concurrent/ListenableFuture;mapperCLorg/elasticsearch/common/base/Function<-Ljava/lang/Exception;TX;>;(Lorg/elasticsearch/common/base/Function;immediateFutureO(Ljava/lang/Object;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Ljavax/annotation/Nullable;(Ljava/lang/Object;)V Lh ,ivalueTV;Ljava/lang/Object;immediateCheckedFutureL(Ljava/lang/Object;)Lorg/elasticsearch/common/util/concurrent/CheckedFuture; )iimmediateFailedFutureR(Ljava/lang/Throwable;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;(Ljava/lang/Throwable;)V Ls &t throwableLjava/lang/Throwable;immediateCancelledFuture=()Lorg/elasticsearch/common/util/concurrent/ListenableFuture; #NimmediateFailedCheckedFutureO(Ljava/lang/Exception;)Lorg/elasticsearch/common/util/concurrent/CheckedFuture;(Ljava/lang/Exception;)V L} ~ exceptionTX;Ljava/lang/Exception; withFallback(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/FutureFallback;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;6org/elasticsearch/common/util/concurrent/MoreExecutorsdirectExecutor!()Ljava/util/concurrent/Executor; (Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/FutureFallback;Ljava/util/concurrent/Executor;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture; inputALorg/elasticsearch/common/util/concurrent/ListenableFuture<+TV;>;fallback?Lorg/elasticsearch/common/util/concurrent/FutureFallback<+TV;>;9Lorg/elasticsearch/common/util/concurrent/FutureFallback;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/FutureFallback;Ljava/util/concurrent/Executor;)V L executorLjava/util/concurrent/Executor; transform(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/AsyncFunction;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;(Lorg/elasticsearch/common/util/concurrent/AsyncFunction;Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/Futures$1;)V L  addListener6(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V [@Lorg/elasticsearch/common/util/concurrent/ListenableFuture;functionBLorg/elasticsearch/common/util/concurrent/AsyncFunction<-TI;+TO;>;outputSLorg/elasticsearch/common/util/concurrent/Futures$ChainingListenableFuture;KLorg/elasticsearch/common/util/concurrent/Futures$ChainingListenableFuture;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;rejectionPropagatingRunnable(Lorg/elasticsearch/common/util/concurrent/AbstractFuture;Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)Ljava/lang/Runnable; o(Ljava/util/concurrent/Executor;Ljava/lang/Runnable;Lorg/elasticsearch/common/util/concurrent/AbstractFuture;)V L @ outputFuture;9Lorg/elasticsearch/common/util/concurrent/AbstractFuture; delegateTaskLjava/lang/Runnable;delegateExecutor(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/base/Function;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;asAsyncFunctionb(Lorg/elasticsearch/common/base/Function;)Lorg/elasticsearch/common/util/concurrent/AsyncFunction; 2Lorg/elasticsearch/common/base/Function<-TI;+TO;>;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/base/Function;Ljava/util/concurrent/Executor;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture; +(Lorg/elasticsearch/common/base/Function;)V L > lazyTransformd(Ljava/util/concurrent/Future;Lorg/elasticsearch/common/base/Function;)Ljava/util/concurrent/Future;H(Ljava/util/concurrent/Future;Lorg/elasticsearch/common/base/Function;)V L <"Ljava/util/concurrent/Future;Ljava/util/concurrent/Future; dereferencex(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture; FG  nestedLorg/elasticsearch/common/util/concurrent/ListenableFuture<+Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TV;>;>; allAsListy([Lorg/elasticsearch/common/util/concurrent/ListenableFuture;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;copyOfE([Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableList; D listFuture(Lorg/elasticsearch/common/collect/ImmutableList;ZLjava/util/concurrent/Executor;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture; futuresB[Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TV;>;<[Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Q(Ljava/lang/Iterable;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;F(Ljava/lang/Iterable;)Lorg/elasticsearch/common/collect/ImmutableList; DXLjava/lang/Iterable<+Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TV;>;>;Ljava/lang/Iterable;nonCancellationPropagating>(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;)V L successfulAsListinCompletionOrder'org/elasticsearch/common/collect/QueuesnewConcurrentLinkedQueue.()Ljava/util/concurrent/ConcurrentLinkedQueue; builder:()Lorg/elasticsearch/common/collect/ImmutableList$Builder; D;>Lorg/elasticsearch/common/util/concurrent/AsyncSettableFuture;ALorg/elasticsearch/common/util/concurrent/ListenableFuture<+TT;>;i$Ljava/util/Iterator;XLjava/lang/Iterable<+Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TT;>;>; delegatesqLjava/util/concurrent/ConcurrentLinkedQueue;>;,Ljava/util/concurrent/ConcurrentLinkedQueue; listBuilderzLorg/elasticsearch/common/collect/ImmutableList$Builder;>;8Lorg/elasticsearch/common/collect/ImmutableList$Builder;>Lorg/elasticsearch/common/util/concurrent/SerializingExecutor; addCallbackw(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/FutureCallback;)V(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/FutureCallback;Ljava/util/concurrent/Executor;)V ,. /callback?Lorg/elasticsearch/common/util/concurrent/FutureCallback<-TV;>;9Lorg/elasticsearch/common/util/concurrent/FutureCallback; L- 64callbackListenergetB(Ljava/util/concurrent/Future;Ljava/lang/Class;)Ljava/lang/Object;java/lang/Exception9java/lang/InterruptedException;'java/util/concurrent/ExecutionException=java/lang/RuntimeException?java/lang/ClassAisAssignableFrom(Ljava/lang/Class;)Z CD BE>Futures.get exception type (%s) must not be a RuntimeExceptionG checkArgument)(ZLjava/lang/String;[Ljava/lang/Object;)V IJ UKjava/util/concurrent/FutureM 7 NOjava/lang/ThreadQ currentThread()Ljava/lang/Thread; ST RU interrupt WM RX newWithCause=(Ljava/lang/Class;Ljava/lang/Throwable;)Ljava/lang/Exception; Z[ \getCause()Ljava/lang/Throwable; ^_ >`wrapAndThrowExceptionOrError)(Ljava/lang/Throwable;Ljava/lang/Class;)V bc djava/lang/AssertionErrorf gNe Ljava/lang/InterruptedException;)Ljava/util/concurrent/ExecutionException;"Ljava/util/concurrent/Future;exceptionClassLjava/lang/Class;Ljava/lang/Class;b(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;Ljava/lang/Class;)Ljava/lang/Object;%java/util/concurrent/TimeoutExceptionq4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object; 7s Nt'Ljava/util/concurrent/TimeoutException;timeoutJunitLjava/util/concurrent/TimeUnit;java/lang/Error{7org/elasticsearch/common/util/concurrent/ExecutionError}(Ljava/lang/Error;)V L ~Dorg/elasticsearch/common/util/concurrent/UncheckedExecutionException tcause getUnchecked1(Ljava/util/concurrent/Future;)Ljava/lang/Object;9org/elasticsearch/common/util/concurrent/UninterruptiblesgetUninterruptibly  wrapAndThrowUnchecked s getConstructors"()[Ljava/lang/reflect/Constructor;  Bjava/util/ArraysasList%([Ljava/lang/Object;)Ljava/util/List;  preferringStrings"(Ljava/util/List;)Ljava/util/List;  java/util/List java/lang/reflect/ConstructornewFromConstructorH(Ljava/lang/reflect/Constructor;Ljava/lang/Throwable;)Ljava/lang/Object;   :` initCause,(Ljava/lang/Throwable;)Ljava/lang/Throwable;  :"java/lang/IllegalArgumentExceptionjava/lang/StringvalueOf&(Ljava/lang/Object;)Ljava/lang/String;  java/lang/StringBuilderlength()I  (I)V L 1No appropriate constructor for exception of type append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  ! in response to chained exceptiontoString()Ljava/lang/String;  *(Ljava/lang/String;Ljava/lang/Throwable;)V L instance constructor$Ljava/lang/reflect/Constructor;Ljava/lang/reflect/Constructor; constructors6Ljava/util/List;>;Ljava/util/List; IJ )org/elasticsearch/common/collect/Ordering sortedCopy&(Ljava/lang/Iterable;)Ljava/util/List;   java/lang/InstantiationException java/lang/IllegalAccessException+java/lang/reflect/InvocationTargetExceptiongetParameterTypes()[Ljava/lang/Class;  [Ljava/lang/Class;[Ljava/lang/Object;equals  java/lang/Throwable  newInstance'([Ljava/lang/Object;)Ljava/lang/Object;   paramTypeLjava/lang/Class<*>;iI$Ljava/lang/IllegalArgumentException;"Ljava/lang/InstantiationException;"Ljava/lang/IllegalAccessException;-Ljava/lang/reflect/InvocationTargetException; paramTypes[Ljava/lang/Class<*>;params 2N(Lorg/elasticsearch/common/collect/ImmutableCollection;ZLjava/util/concurrent/Executor;Lorg/elasticsearch/common/util/concurrent/Futures$FutureCombiner;)V L sLorg/elasticsearch/common/collect/ImmutableList;>;0Lorg/elasticsearch/common/collect/ImmutableList;allMustSucceedZlistenerExecutor :Nnatural-()Lorg/elasticsearch/common/collect/Ordering;    4N onResultOfU(Lorg/elasticsearch/common/base/Function;)Lorg/elasticsearch/common/collect/Ordering;  reverse   SignatureCodeLocalVariableTableLineNumberTableLocalVariableTypeTable(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/base/Function<-Ljava/lang/Exception;TX;>;)Lorg/elasticsearch/common/util/concurrent/CheckedFuture;[(TV;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;"RuntimeVisibleParameterAnnotationsr(TV;)Lorg/elasticsearch/common/util/concurrent/CheckedFuture;m(Ljava/lang/Throwable;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;X()Lorg/elasticsearch/common/util/concurrent/ListenableFuture;r(TX;)Lorg/elasticsearch/common/util/concurrent/CheckedFuture;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TV;>;Lorg/elasticsearch/common/util/concurrent/FutureFallback<+TV;>;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TV;>;Lorg/elasticsearch/common/util/concurrent/FutureFallback<+TV;>;Ljava/util/concurrent/Executor;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/AsyncFunction<-TI;+TO;>;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture; (Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/AsyncFunction<-TI;+TO;>;Ljava/util/concurrent/Executor;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;(Lorg/elasticsearch/common/util/concurrent/AbstractFuture<*>;Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)Ljava/lang/Runnable;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/base/Function<-TI;+TO;>;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/base/Function<-TI;+TO;>;Ljava/util/concurrent/Executor;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;(Lorg/elasticsearch/common/base/Function<-TI;+TO;>;)Lorg/elasticsearch/common/util/concurrent/AsyncFunction;(Ljava/util/concurrent/Future;Lorg/elasticsearch/common/base/Function<-TI;+TO;>;)Ljava/util/concurrent/Future;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TV;>;>;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;([Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TV;>;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;>;RuntimeInvisibleAnnotations(Ljava/lang/Iterable<+Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TV;>;>;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;>;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture; StackMapTable(Ljava/lang/Iterable<+Lorg/elasticsearch/common/util/concurrent/ListenableFuture<+TT;>;>;)Lorg/elasticsearch/common/collect/ImmutableList;>;(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/FutureCallback<-TV;>;)V(Lorg/elasticsearch/common/util/concurrent/ListenableFuture;Lorg/elasticsearch/common/util/concurrent/FutureCallback<-TV;>;Ljava/util/concurrent/Executor;)V Exceptionsn(Ljava/util/concurrent/Future;Ljava/lang/Class;)TV;^TX;(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;Ljava/lang/Class;)TV;^TX;K(Ljava/lang/Throwable;Ljava/lang/Class;)V^TX;=(Ljava/util/concurrent/Future;)TV;I(Ljava/lang/Class;Ljava/lang/Throwable;)TX;(Ljava/util/List;>;)Ljava/util/List;>;T(Ljava/lang/reflect/Constructor;Ljava/lang/Throwable;)TX;RuntimeVisibleAnnotations(Lorg/elasticsearch/common/collect/ImmutableList;>;ZLjava/util/concurrent/Executor;)Lorg/elasticsearch/common/util/concurrent/ListenableFuture;>; SourceFile InnerClasses1FGHIJK#LM/*O PQL RS`Y*Y[+^_abd_`bc\ efE ,Y*j  km  klg noE )Y*p  km  klg qr<*YW&Y*u vw  xy #Yz {|N*YW Y*   ,- Y *+ a  {! n+YWY*+, a " Y+*M*,, aG   5 78# !,YWY+*N*--,-*!a!G! !!efhi$ [ @Y,+*     t% +YWY+*M*,, ad   & m+YW*+, ad ' E >Y*  d  ( l*YW+YW"#^Z%'V(*K+46 1%_!^$Z%&V()* 16=OVY/B=0, ,-] *+0 _a 13 _` 12 1 ,.+YW6Y*+5N*-,*_a13 6_`12*+2 78G*YW@+FHY+SL*PMVY+,]M,a+egYh"()<"(6>** ij7ikG_GmoG_lGmn& ^_"c)d*e0f6g7h?i/ @T3:4 7p=`*YW-YW@FHYSL*-u:VY]:]:aegYh)12<)1Br)1L>H4ijDivNik`_`wx`yz`mo`_l`mn2  )24:BDLNX/@W3:5 bc)*|~Y*|*@ Y*+*])w)mo )mn#/3:6 *YW*L+agYh > ik_ _l  /J>7 sW*|~Y*|Y* w/ Z[I}*M,N-3- :+:: +WʻY*NYR-`-Ķ¶+˿>1&"9"#}mo}wu*1&"}mnu&  &16>EHK/2:8 D*ڰ  9 b*M,N6,:,2:-+S -+S*-::::LQRLQVLQZLQ^f +o>TiXi\i`ibbw] W +b]N+, -./&011<2D4F-L8R9T:V;X<Z=\>^?`@/) "BECCC:;g b Y*,2Y  <M::Y˸ 4Y Ա  "=>      ! #$ &' )* ,- /0 2468:<>@BDE,