src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/HttpClientFacade.java
equal
deleted
inserted
replaced
34 import java.util.Optional; |
34 import java.util.Optional; |
35 import java.util.concurrent.CompletableFuture; |
35 import java.util.concurrent.CompletableFuture; |
36 import java.util.concurrent.Executor; |
36 import java.util.concurrent.Executor; |
37 import javax.net.ssl.SSLContext; |
37 import javax.net.ssl.SSLContext; |
38 import javax.net.ssl.SSLParameters; |
38 import javax.net.ssl.SSLParameters; |
|
39 import jdk.incubator.http.HttpResponse.BodyHandler; |
|
40 import jdk.incubator.http.HttpResponse.PushPromiseHandler; |
39 |
41 |
40 /** |
42 /** |
41 * An HttpClientFacade is a simple class that wraps an HttpClient implementation |
43 * An HttpClientFacade is a simple class that wraps an HttpClient implementation |
42 * and delegates everything to its implementation delegate. |
44 * and delegates everything to its implementation delegate. |
43 */ |
45 */ |
113 Reference.reachabilityFence(this); |
115 Reference.reachabilityFence(this); |
114 } |
116 } |
115 } |
117 } |
116 |
118 |
117 @Override |
119 @Override |
118 public <U, T> CompletableFuture<U> |
120 public <T> CompletableFuture<HttpResponse<T>> |
119 sendAsync(HttpRequest req, HttpResponse.MultiSubscriber<U, T> multiSubscriber) { |
121 sendAsync(HttpRequest req, |
|
122 BodyHandler<T> responseBodyHandler, |
|
123 PushPromiseHandler<T> pushPromiseHandler){ |
120 try { |
124 try { |
121 return impl.sendAsync(req, multiSubscriber); |
125 return impl.sendAsync(req, responseBodyHandler, pushPromiseHandler); |
122 } finally { |
126 } finally { |
123 Reference.reachabilityFence(this); |
127 Reference.reachabilityFence(this); |
124 } |
128 } |
125 } |
129 } |
126 |
130 |