diff options
author | Colin Cross <ccross@android.com> | 2019-04-11 14:32:53 -0700 |
---|---|---|
committer | Colin Cross <ccross@android.com> | 2019-04-15 15:33:46 -0700 |
commit | a798701c6f9496a034d0fedad00162061b3526c3 (patch) | |
tree | a4266fefed8c06645acf1cabc745a90bf583d670 /src/com/android/contacts/util | |
parent | 0ad1375cd6f312b8f81b999aae296ba813080923 (diff) | |
download | Contacts-a798701c6f9496a034d0fedad00162061b3526c3.tar.gz |
Update Contacts for guava 27.1
Futures.transform now requires an Executor argument.
Futures.withFallback has been replaced with Futures.catchingAsync.
Bug: 130306229
Test: m checkbuild
Change-Id: I5ea7810446ed23b133e6dfb0eb06e6e10125db53
Diffstat (limited to 'src/com/android/contacts/util')
-rw-r--r-- | src/com/android/contacts/util/concurrent/FuturesUtil.java | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/com/android/contacts/util/concurrent/FuturesUtil.java b/src/com/android/contacts/util/concurrent/FuturesUtil.java index 113af93ce..ba724468e 100644 --- a/src/com/android/contacts/util/concurrent/FuturesUtil.java +++ b/src/com/android/contacts/util/concurrent/FuturesUtil.java @@ -3,9 +3,10 @@ package com.android.contacts.util.concurrent; import android.os.Handler; -import com.google.common.util.concurrent.FutureFallback; +import com.google.common.util.concurrent.AsyncFunction; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; +import com.google.common.util.concurrent.MoreExecutors; import java.util.concurrent.CancellationException; import java.util.concurrent.ScheduledExecutorService; @@ -46,14 +47,14 @@ public class FuturesUtil { } }, time, unit); - return Futures.withFallback(future, new FutureFallback<V>() { + return Futures.catchingAsync(future, Throwable.class, new AsyncFunction<Throwable, V>() { @Override - public ListenableFuture<V> create(Throwable t) throws Exception { + public ListenableFuture<V> apply(Throwable t) throws Exception { if ((t instanceof CancellationException) && didTimeout.get()) { return Futures.immediateFailedFuture(new TimeoutException("Timeout expired")); } return Futures.immediateFailedFuture(t); } - }); + }, MoreExecutors.directExecutor()); } } |