aboutsummaryrefslogtreecommitdiffstats
path: root/container-core/src/main/java/com/yahoo/processing/response/AbstractDataList.java
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2021-12-08 16:33:54 +0100
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2021-12-08 16:34:03 +0100
commitef0b4d55f482fe8b4dc6dadbd41b21264ea1b956 (patch)
treea1545e49fa018b93c37ea9953955420df97d123b /container-core/src/main/java/com/yahoo/processing/response/AbstractDataList.java
parentbf9d4b9ab1151de895f7e3375717d6e0ef1918e7 (diff)
Rename method 'future' => 'completedFuture'
Diffstat (limited to 'container-core/src/main/java/com/yahoo/processing/response/AbstractDataList.java')
-rw-r--r--container-core/src/main/java/com/yahoo/processing/response/AbstractDataList.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/container-core/src/main/java/com/yahoo/processing/response/AbstractDataList.java b/container-core/src/main/java/com/yahoo/processing/response/AbstractDataList.java
index d4dd59cdd59..b1ce0643487 100644
--- a/container-core/src/main/java/com/yahoo/processing/response/AbstractDataList.java
+++ b/container-core/src/main/java/com/yahoo/processing/response/AbstractDataList.java
@@ -140,7 +140,7 @@ public abstract class AbstractDataList<DATATYPE extends Data> extends Listenable
*/
@Override
public DataList<DATATYPE> get() throws InterruptedException, ExecutionException {
- return drain(owner.incoming().future().get());
+ return drain(owner.incoming().completedFuture().get());
}
/**
@@ -149,7 +149,7 @@ public abstract class AbstractDataList<DATATYPE extends Data> extends Listenable
*/
@Override
public DataList<DATATYPE> get(long timeout, TimeUnit timeUnit) throws InterruptedException, ExecutionException, TimeoutException {
- return drain(owner.incoming().future().get(timeout, timeUnit));
+ return drain(owner.incoming().completedFuture().get(timeout, timeUnit));
}
private DataList<DATATYPE> drain(DataList<DATATYPE> dataList) {