(ContinueResponseTiming continueResponseTiming)
| 275 | |
| 276 | |
| 277 | @Override |
| 278 | protected final void ack(ContinueResponseTiming continueResponseTiming) { |
| 279 | // Only try and send the ACK for ALWAYS or if the timing of the request |
| 280 | // to send the ACK matches the current configuration. |
| 281 | if (continueResponseTiming == ContinueResponseTiming.ALWAYS || |
| 282 | continueResponseTiming == handler.getProtocol().getContinueResponseTimingInternal()) { |
| 283 | if (!response.isCommitted() && request.hasExpectation()) { |
| 284 | try { |
| 285 | stream.writeAck(); |
| 286 | } catch (IOException ioe) { |
| 287 | setErrorState(ErrorState.CLOSE_CONNECTION_NOW, ioe); |
| 288 | } |
| 289 | } |
| 290 | } |
| 291 | } |
| 292 | |
| 293 | |
| 294 | @Override |
no test coverage detected