--- a/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/websocket/WebSocketImpl.java Tue Nov 21 20:38:12 2017 +0000
+++ b/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/websocket/WebSocketImpl.java Wed Nov 22 11:30:24 2017 +0300
@@ -63,7 +63,7 @@
import static java.lang.String.format;
import static java.util.Objects.requireNonNull;
-import static java.util.concurrent.CompletableFuture.failedFuture;
+import static jdk.incubator.http.internal.common.MinimalFuture.failedFuture;
import static jdk.incubator.http.internal.common.Pair.pair;
import static jdk.incubator.http.internal.common.Utils.permissionForProxy;
import static jdk.incubator.http.internal.websocket.StatusCodes.CLOSED_ABNORMALLY;
@@ -304,7 +304,7 @@
}
CompletionStage<?> readyToClose = signalClose(statusCode, reason);
if (readyToClose == null) {
- readyToClose = CompletableFuture.completedFuture(null);
+ readyToClose = MinimalFuture.completedFuture(null);
}
readyToClose.whenComplete((r, error) -> {
enqueueClose(new Close(code, ""))