aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/result/HitGroup.java
diff options
context:
space:
mode:
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/result/HitGroup.java')
-rw-r--r--container-search/src/main/java/com/yahoo/search/result/HitGroup.java12
1 files changed, 10 insertions, 2 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/result/HitGroup.java b/container-search/src/main/java/com/yahoo/search/result/HitGroup.java
index 1ae3f4e60cc..b3704c379fe 100644
--- a/container-search/src/main/java/com/yahoo/search/result/HitGroup.java
+++ b/container-search/src/main/java/com/yahoo/search/result/HitGroup.java
@@ -5,6 +5,7 @@ import com.google.common.base.Predicate;
import com.google.common.collect.Iterables;
import com.google.common.util.concurrent.ListenableFuture;
import com.yahoo.collections.ListenableArrayList;
+import com.yahoo.concurrent.CompletableFutures;
import com.yahoo.net.URI;
import com.yahoo.prelude.fastsearch.SortDataHitSorter;
import com.yahoo.processing.response.ArrayDataList;
@@ -19,6 +20,7 @@ import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
+import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
/**
@@ -84,7 +86,7 @@ public class HitGroup extends Hit implements DataList<Hit>, Cloneable, Iterable<
*/
private DefaultErrorHit errorHit = null;
- private final ListenableFuture<DataList<Hit>> completedFuture;
+ private final CompletableFuture<DataList<Hit>> completedFuture;
private final IncomingData<Hit> incomingHits;
@@ -965,7 +967,13 @@ public class HitGroup extends Hit implements DataList<Hit>, Cloneable, Iterable<
public IncomingData<Hit> incoming() { return incomingHits; }
@Override
- public ListenableFuture<DataList<Hit>> complete() { return completedFuture; }
+ @SuppressWarnings("removal")
+ @Deprecated(forRemoval = true, since = "7")
+ public ListenableFuture<DataList<Hit>> complete() {
+ return CompletableFutures.toGuavaListenableFuture(completedFuture);
+ }
+
+ @Override public CompletableFuture<DataList<Hit>> future() { return completedFuture; }
@Override
public void addDataListener(Runnable runnable) {