equal
deleted
inserted
replaced
373 refCountTracker.acquire(); |
373 refCountTracker.acquire(); |
374 bodyReader.start(content.getBodyParser( |
374 bodyReader.start(content.getBodyParser( |
375 (t) -> { |
375 (t) -> { |
376 try { |
376 try { |
377 if (t != null) { |
377 if (t != null) { |
378 subscriber.onError(t); |
378 try { |
379 connection.close(); |
379 subscriber.onError(t); |
380 cf.completeExceptionally(t); |
380 } finally { |
|
381 cf.completeExceptionally(t); |
|
382 } |
381 } |
383 } |
382 } finally { |
384 } finally { |
383 bodyReader.onComplete(t); |
385 bodyReader.onComplete(t); |
|
386 if (t != null) { |
|
387 connection.close(); |
|
388 } |
384 } |
389 } |
385 })); |
390 })); |
386 CompletableFuture<State> bodyReaderCF = bodyReader.completion(); |
391 CompletableFuture<State> bodyReaderCF = bodyReader.completion(); |
387 asyncReceiver.subscribe(bodyReader); |
392 asyncReceiver.subscribe(bodyReader); |
388 assert bodyReaderCF != null : "parsing not started"; |
393 assert bodyReaderCF != null : "parsing not started"; |