Skip to content

Commit 31d9777

Browse files
committed
Fix formatting
1 parent b962b28 commit 31d9777

1 file changed

Lines changed: 4 additions & 6 deletions

File tree

httpcore5-reactive/src/main/java/org/apache/hc/core5/reactive/ReactiveResponseConsumer.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -184,10 +184,10 @@ public List<Header> getTrailers() {
184184

185185
@Override
186186
public void consumeResponse(
187-
final HttpResponse response,
188-
final EntityDetails entityDetails,
189-
final HttpContext httpContext,
190-
final FutureCallback<Void> resultCallback
187+
final HttpResponse response,
188+
final EntityDetails entityDetails,
189+
final HttpContext httpContext,
190+
final FutureCallback<Void> resultCallback
191191
) {
192192
this.entityDetails = entityDetails;
193193
this.responseCompletion = new BasicFuture<>(resultCallback);
@@ -209,8 +209,6 @@ public void informationResponse(final HttpResponse response, final HttpContext h
209209
@Override
210210
public void failed(final Exception cause) {
211211
reactiveDataConsumer.failed(cause);
212-
213-
// Complete stage/futures regardless of whether consumeResponse() has been invoked yet.
214212
responseFuture.failed(cause);
215213
responseCompletableFuture.completeExceptionally(cause);
216214
responseCompletionFuture.completeExceptionally(cause);

0 commit comments

Comments
 (0)