src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/common/SubscriberWrapper.java
equal
deleted
inserted
replaced
375 @Override |
375 @Override |
376 public void onComplete() { |
376 public void onComplete() { |
377 logger.log(Level.DEBUG, () -> "upstream completed: " + toString()); |
377 logger.log(Level.DEBUG, () -> "upstream completed: " + toString()); |
378 upstreamCompleted = true; |
378 upstreamCompleted = true; |
379 incomingCaller(Utils.EMPTY_BB_LIST, true); |
379 incomingCaller(Utils.EMPTY_BB_LIST, true); |
380 checkCompletion(); |
380 // pushScheduler will call checkCompletion() |
381 pushScheduler.runOrSchedule(); |
381 pushScheduler.runOrSchedule(); |
382 } |
382 } |
383 |
383 |
384 /** Adds the given data to the input queue. */ |
384 /** Adds the given data to the input queue. */ |
385 public void addData(ByteBuffer l) { |
385 public void addData(ByteBuffer l) { |