.class public abstract Lcom/google/common/util/concurrent/FluentFuture; .super Lcom/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization; .source "FluentFuture.java" # annotations .annotation build Lcom/google/common/annotations/Beta; .end annotation .annotation build Lcom/google/common/annotations/GwtCompatible; emulated = true .end annotation .annotation runtime Lcom/google/common/util/concurrent/ElementTypesAreNonnullByDefault; .end annotation .annotation runtime Lcom/google/errorprone/annotations/DoNotMock; value = "Use FluentFuture.from(Futures.immediate*Future) or SettableFuture" .end annotation .annotation system Ldalvik/annotation/MemberClasses; value = { Lcom/google/common/util/concurrent/FluentFuture$TrustedFuture; } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "", "Lcom/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization<", "TV;>;" } .end annotation # direct methods .method public constructor ()V .locals 0 .line 1 invoke-direct {p0}, Lcom/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization;->()V return-void .end method .method public static from(Lcom/google/common/util/concurrent/FluentFuture;)Lcom/google/common/util/concurrent/FluentFuture; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lcom/google/common/util/concurrent/FluentFuture<", "TV;>;)", "Lcom/google/common/util/concurrent/FluentFuture<", "TV;>;" } .end annotation .annotation runtime Ljava/lang/Deprecated; .end annotation .line 4 invoke-static {p0}, Lcom/google/common/base/Preconditions;->checkNotNull(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p0 check-cast p0, Lcom/google/common/util/concurrent/FluentFuture; return-object p0 .end method .method public static from(Lcom/google/common/util/concurrent/ListenableFuture;)Lcom/google/common/util/concurrent/FluentFuture; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lcom/google/common/util/concurrent/ListenableFuture<", "TV;>;)", "Lcom/google/common/util/concurrent/FluentFuture<", "TV;>;" } .end annotation .line 1 instance-of v0, p0, Lcom/google/common/util/concurrent/FluentFuture; if-eqz v0, :cond_0 .line 2 check-cast p0, Lcom/google/common/util/concurrent/FluentFuture; goto :goto_0 .line 3 :cond_0 new-instance v0, Lcom/google/common/util/concurrent/ForwardingFluentFuture; invoke-direct {v0, p0}, Lcom/google/common/util/concurrent/ForwardingFluentFuture;->(Lcom/google/common/util/concurrent/ListenableFuture;)V move-object p0, v0 :goto_0 return-object p0 .end method # virtual methods .method public final addCallback(Lcom/google/common/util/concurrent/FutureCallback;Ljava/util/concurrent/Executor;)V .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lcom/google/common/util/concurrent/FutureCallback<", "-TV;>;", "Ljava/util/concurrent/Executor;", ")V" } .end annotation .line 1 invoke-static {p0, p1, p2}, Lcom/google/common/util/concurrent/Futures;->addCallback(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/FutureCallback;Ljava/util/concurrent/Executor;)V return-void .end method .method public final catching(Ljava/lang/Class;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/FluentFuture; .locals 0 .annotation build Lcom/google/common/util/concurrent/Partially$GwtIncompatible; value = "AVAILABLE but requires exceptionType to be Throwable.class" .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "TX;>;", "Lcom/google/common/base/Function<", "-TX;+TV;>;", "Ljava/util/concurrent/Executor;", ")", "Lcom/google/common/util/concurrent/FluentFuture<", "TV;>;" } .end annotation .line 1 invoke-static {p0, p1, p2, p3}, Lcom/google/common/util/concurrent/Futures;->catching(Lcom/google/common/util/concurrent/ListenableFuture;Ljava/lang/Class;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture; move-result-object p1 check-cast p1, Lcom/google/common/util/concurrent/FluentFuture; return-object p1 .end method .method public final catchingAsync(Ljava/lang/Class;Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/FluentFuture; .locals 0 .annotation build Lcom/google/common/util/concurrent/Partially$GwtIncompatible; value = "AVAILABLE but requires exceptionType to be Throwable.class" .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "TX;>;", "Lcom/google/common/util/concurrent/AsyncFunction<", "-TX;+TV;>;", "Ljava/util/concurrent/Executor;", ")", "Lcom/google/common/util/concurrent/FluentFuture<", "TV;>;" } .end annotation .line 1 invoke-static {p0, p1, p2, p3}, Lcom/google/common/util/concurrent/Futures;->catchingAsync(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; move-result-object p1 check-cast p1, Lcom/google/common/util/concurrent/FluentFuture; return-object p1 .end method .method public final transform(Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/FluentFuture; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lcom/google/common/base/Function<", "-TV;TT;>;", "Ljava/util/concurrent/Executor;", ")", "Lcom/google/common/util/concurrent/FluentFuture<", "TT;>;" } .end annotation .line 1 invoke-static {p0, p1, p2}, Lcom/google/common/util/concurrent/Futures;->transform(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture; move-result-object p1 check-cast p1, Lcom/google/common/util/concurrent/FluentFuture; return-object p1 .end method .method public final transformAsync(Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/FluentFuture; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lcom/google/common/util/concurrent/AsyncFunction<", "-TV;TT;>;", "Ljava/util/concurrent/Executor;", ")", "Lcom/google/common/util/concurrent/FluentFuture<", "TT;>;" } .end annotation .line 1 invoke-static {p0, p1, p2}, Lcom/google/common/util/concurrent/Futures;->transformAsync(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/AsyncFunction;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture; move-result-object p1 check-cast p1, Lcom/google/common/util/concurrent/FluentFuture; return-object p1 .end method .method public final withTimeout(JLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/common/util/concurrent/FluentFuture; .locals 0 .annotation build Lcom/google/common/annotations/GwtIncompatible; .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Ljava/util/concurrent/ScheduledExecutorService;", ")", "Lcom/google/common/util/concurrent/FluentFuture<", "TV;>;" } .end annotation .line 1 invoke-static {p0, p1, p2, p3, p4}, Lcom/google/common/util/concurrent/Futures;->withTimeout(Lcom/google/common/util/concurrent/ListenableFuture;JLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/common/util/concurrent/ListenableFuture; move-result-object p1 check-cast p1, Lcom/google/common/util/concurrent/FluentFuture; return-object p1 .end method