src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/ResponseSubscribers.java
equal
deleted
inserted
replaced
60 private Flow.Subscription subscription; |
60 private Flow.Subscription subscription; |
61 private final CompletableFuture<Void> result = new MinimalFuture<>(); |
61 private final CompletableFuture<Void> result = new MinimalFuture<>(); |
62 private final AtomicBoolean subscribed = new AtomicBoolean(); |
62 private final AtomicBoolean subscribed = new AtomicBoolean(); |
63 |
63 |
64 ConsumerSubscriber(Consumer<Optional<byte[]>> consumer) { |
64 ConsumerSubscriber(Consumer<Optional<byte[]>> consumer) { |
65 this.consumer = consumer; |
65 this.consumer = Objects.requireNonNull(consumer); |
66 } |
66 } |
67 |
67 |
68 @Override |
68 @Override |
69 public CompletionStage<Void> getBody() { |
69 public CompletionStage<Void> getBody() { |
70 return result; |
70 return result; |