Mercurial Mercurial > jdk-sandbox / changeset
summary | shortlog | changelog | graph | tags | bookmarks | branches | files | changeset | raw | help
Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
http-client-branch: test change missed in last push http-client-branch
authormichaelm
Tue, 10 Apr 2018 15:26:58 +0100
branchhttp-client-branch
changeset 56411 700f23d8f4fb
parent 56410 1b37529eaf3a
child 56412 d705071e390c
http-client-branch: test change missed in last push
test/jdk/java/net/httpclient/InvalidInputStreamSubscriptionRequest.java file | annotate | diff | comparison | revisions 
--- a/test/jdk/java/net/httpclient/InvalidInputStreamSubscriptionRequest.java	Tue Apr 10 15:04:27 2018 +0100
+++ b/test/jdk/java/net/httpclient/InvalidInputStreamSubscriptionRequest.java	Tue Apr 10 15:26:58 2018 +0100
@@ -219,8 +219,8 @@
             HttpRequest req = HttpRequest.newBuilder(URI.create(uri))
                     .build();
             BodyHandler<InputStream> handler = handlers.get();
-            BodyHandler<InputStream> badHandler = (c,h) ->
-                    new BadBodySubscriber<>(handler.apply(c,h));
+            BodyHandler<InputStream> badHandler = (rspinfo) ->
+                    new BadBodySubscriber<>(handler.apply(rspinfo));
             try {
                 HttpResponse<InputStream> response = client.send(req, badHandler);
                 try (InputStream is = response.body()) {
@@ -260,8 +260,8 @@
             HttpRequest req = HttpRequest.newBuilder(URI.create(uri))
                     .build();
             BodyHandler<InputStream> handler = handlers.get();
-            BodyHandler<InputStream> badHandler = (c,h) ->
-                    new BadBodySubscriber<>(handler.apply(c,h));
+            BodyHandler<InputStream> badHandler = (rspinfo) ->
+                    new BadBodySubscriber<>(handler.apply(rspinfo));
             CompletableFuture<HttpResponse<InputStream>> response =
                     client.sendAsync(req, badHandler);
             CompletableFuture<String> result = response.thenCompose(
@@ -309,8 +309,8 @@
             HttpRequest req = HttpRequest.newBuilder(URI.create(uri+"/withBody"))
                     .build();
             BodyHandler<InputStream> handler = handlers.get();
-            BodyHandler<InputStream> badHandler = (c,h) ->
-                    new BadBodySubscriber<>(handler.apply(c,h));
+            BodyHandler<InputStream> badHandler = (rspinfo) ->
+                    new BadBodySubscriber<>(handler.apply(rspinfo));
             try {
                 HttpResponse<InputStream> response = client.send(req, badHandler);
                 try (InputStream is = response.body()) {
@@ -345,8 +345,8 @@
             HttpRequest req = HttpRequest.newBuilder(URI.create(uri+"/withBody"))
                     .build();
             BodyHandler<InputStream> handler = handlers.get();
-            BodyHandler<InputStream> badHandler = (c,h) ->
-                    new BadBodySubscriber<>(handler.apply(c,h));
+            BodyHandler<InputStream> badHandler = (rspinfo) ->
+                    new BadBodySubscriber<>(handler.apply(rspinfo));
             CompletableFuture<String> result = client.sendAsync(req, badHandler)
                     .thenCompose((responsePublisher) -> {
                         try (InputStream is = responsePublisher.body()) {
jdk-sandbox