equal
deleted
inserted
replaced
475 |
475 |
476 synchronized (lock) { |
476 synchronized (lock) { |
477 if (dp.throwable != null) { |
477 if (dp.throwable != null) { |
478 state = State.ERROR; |
478 state = State.ERROR; |
479 exec.execute(() -> { |
479 exec.execute(() -> { |
480 connection.close(); |
|
481 headersSentCF.completeExceptionally(dp.throwable); |
480 headersSentCF.completeExceptionally(dp.throwable); |
482 bodySentCF.completeExceptionally(dp.throwable); |
481 bodySentCF.completeExceptionally(dp.throwable); |
|
482 connection.close(); |
483 }); |
483 }); |
484 return dp; |
484 return dp; |
485 } |
485 } |
486 |
486 |
487 switch (state) { |
487 switch (state) { |