src/java.net.http/share/classes/jdk/internal/net/http/Http1AsyncReceiver.java
branchhttp-client-branch
changeset 56399 a0929d5dd63f
parent 56392 9120556e7163
child 56423 ba64c30666cc
--- a/src/java.net.http/share/classes/jdk/internal/net/http/Http1AsyncReceiver.java	Fri Apr 06 18:15:35 2018 +0100
+++ b/src/java.net.http/share/classes/jdk/internal/net/http/Http1AsyncReceiver.java	Fri Apr 06 22:11:44 2018 +0100
@@ -332,7 +332,7 @@
         if (pending != null && pendingDelegateRef.compareAndSet(pending, null)) {
             Http1AsyncDelegate delegate = this.delegate;
             if (delegate != null) unsubscribe(delegate);
-            Consumer<Throwable> onIllegalArg = (x) -> {
+            Consumer<Throwable> onSubscriptionError = (x) -> {
                 setRetryOnError(false);
                 stopRequested = true;
                 onReadError(x);
@@ -356,7 +356,7 @@
             // the header/body parser work with a flow of ByteBuffer, whereas
             // we have a flow List<ByteBuffer> upstream.
             Http1AsyncDelegateSubscription subscription =
-                    new Http1AsyncDelegateSubscription(scheduler, cancel, onIllegalArg);
+                    new Http1AsyncDelegateSubscription(scheduler, cancel, onSubscriptionError);
             pending.onSubscribe(subscription);
             this.delegate = delegate = pending;
             final Object captured = delegate;