src/java.net.http/share/classes/jdk/internal/net/http/Http1Response.java
branchhttp-client-branch
changeset 56288 2de1aa88cf06
parent 56253 875dbf6234f2
child 56392 9120556e7163
--- a/src/java.net.http/share/classes/jdk/internal/net/http/Http1Response.java	Tue Mar 13 10:39:26 2018 +0000
+++ b/src/java.net.http/share/classes/jdk/internal/net/http/Http1Response.java	Tue Mar 13 14:24:15 2018 +0000
@@ -560,7 +560,12 @@
         @Override
         public void onSubscribe(AbstractSubscription s) {
             this.subscription = s;
-            parser.onSubscribe(s);
+            try {
+                parser.onSubscribe(s);
+            } catch (Throwable t) {
+                cf.completeExceptionally(t);
+                throw t;
+            }
         }
 
         @Override