summaryrefslogtreecommitdiffstats
path: root/jdisc_core/src/main/java/com/yahoo/jdisc/handler/FutureResponse.java
diff options
context:
space:
mode:
Diffstat (limited to 'jdisc_core/src/main/java/com/yahoo/jdisc/handler/FutureResponse.java')
-rw-r--r--jdisc_core/src/main/java/com/yahoo/jdisc/handler/FutureResponse.java14
1 files changed, 4 insertions, 10 deletions
diff --git a/jdisc_core/src/main/java/com/yahoo/jdisc/handler/FutureResponse.java b/jdisc_core/src/main/java/com/yahoo/jdisc/handler/FutureResponse.java
index d5eda23a8d6..4730535640c 100644
--- a/jdisc_core/src/main/java/com/yahoo/jdisc/handler/FutureResponse.java
+++ b/jdisc_core/src/main/java/com/yahoo/jdisc/handler/FutureResponse.java
@@ -30,18 +30,10 @@ public final class FutureResponse extends CompletableFuture<Response> implements
*
* @param content The content channel for the Response.
*/
- public FutureResponse(final ContentChannel content) {
- this(new ResponseHandler() {
-
- @Override
- public ContentChannel handleResponse(Response response) {
- return content;
- }
- });
+ public FutureResponse(ContentChannel content) {
+ this(response -> content);
}
- public void addListener(Runnable r, Executor e) { whenCompleteAsync((__, ___) -> r.run(), e); }
-
/**
* <p>Constructs a new FutureResponse that calls the given {@link ResponseHandler} when {@link
* #handleResponse(Response)} is invoked.</p>
@@ -52,6 +44,8 @@ public final class FutureResponse extends CompletableFuture<Response> implements
this.handler = handler;
}
+ public void addListener(Runnable r, Executor e) { whenCompleteAsync((__, ___) -> r.run(), e); }
+
@Override
public ContentChannel handleResponse(Response response) {
complete(response);