diff options
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.java | 14 |
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); |