src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/ResponseContent.java
equal
deleted
inserted
replaced
399 + contentLength +", onSubscribe: " |
399 + contentLength +", onSubscribe: " |
400 + pusher.getClass().getName()); |
400 + pusher.getClass().getName()); |
401 pusher.onSubscribe(this.sub = sub); |
401 pusher.onSubscribe(this.sub = sub); |
402 try { |
402 try { |
403 if (contentLength == 0) { |
403 if (contentLength == 0) { |
|
404 onFinished.run(); |
404 pusher.onComplete(); |
405 pusher.onComplete(); |
405 onFinished.run(); |
|
406 onComplete.accept(null); |
406 onComplete.accept(null); |
407 } |
407 } |
408 } catch (Throwable t) { |
408 } catch (Throwable t) { |
409 closedExceptionally = t; |
409 closedExceptionally = t; |
410 try { |
410 try { |