summaryrefslogtreecommitdiff
path: root/src/com/android/contacts/util
diff options
context:
space:
mode:
authorColin Cross <ccross@android.com>2019-04-11 14:32:53 -0700
committerColin Cross <ccross@android.com>2019-04-15 15:33:46 -0700
commita798701c6f9496a034d0fedad00162061b3526c3 (patch)
treea4266fefed8c06645acf1cabc745a90bf583d670 /src/com/android/contacts/util
parent0ad1375cd6f312b8f81b999aae296ba813080923 (diff)
downloadContacts-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.java9
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());
}
}