aboutsummaryrefslogtreecommitdiffstats
path: root/container-core/src/main/java/com/yahoo/processing/response
diff options
context:
space:
mode:
Diffstat (limited to 'container-core/src/main/java/com/yahoo/processing/response')
-rw-r--r--container-core/src/main/java/com/yahoo/processing/response/DefaultIncomingData.java5
-rw-r--r--container-core/src/main/java/com/yahoo/processing/response/IncomingData.java3
2 files changed, 3 insertions, 5 deletions
diff --git a/container-core/src/main/java/com/yahoo/processing/response/DefaultIncomingData.java b/container-core/src/main/java/com/yahoo/processing/response/DefaultIncomingData.java
index d820c2812e5..ee2e920afcc 100644
--- a/container-core/src/main/java/com/yahoo/processing/response/DefaultIncomingData.java
+++ b/container-core/src/main/java/com/yahoo/processing/response/DefaultIncomingData.java
@@ -5,7 +5,6 @@ import com.yahoo.collections.Tuple2;
import com.yahoo.concurrent.CompletableFutures;
import java.util.ArrayList;
-import java.util.Collections;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executor;
@@ -60,13 +59,13 @@ public class DefaultIncomingData<DATATYPE extends Data> implements IncomingData<
/** Adds new data and marks this as completed */
@Override
public synchronized void addLast(DATATYPE data) {
- addLast(Collections.singletonList(data));
+ addLast(List.of(data));
}
/** Adds new data without completing this */
@Override
public synchronized void add(DATATYPE data) {
- add(Collections.singletonList(data));
+ add(List.of(data));
}
/** Adds new data and marks this as completed */
diff --git a/container-core/src/main/java/com/yahoo/processing/response/IncomingData.java b/container-core/src/main/java/com/yahoo/processing/response/IncomingData.java
index 45dec0ad2ba..fb891f0b8ea 100644
--- a/container-core/src/main/java/com/yahoo/processing/response/IncomingData.java
+++ b/container-core/src/main/java/com/yahoo/processing/response/IncomingData.java
@@ -3,7 +3,6 @@ package com.yahoo.processing.response;
import com.yahoo.processing.impl.ProcessingFuture;
-import java.util.Collections;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executor;
@@ -158,7 +157,7 @@ public interface IncomingData<DATATYPE extends Data> {
}
public List<DATATYPE> drain() {
- return Collections.emptyList();
+ return List.of();
}
/**