(self)
| 319 | self.transport.close() |
| 320 | |
| 321 | def on_response_complete(self) -> None: |
| 322 | self.server_state.total_requests += 1 |
| 323 | |
| 324 | if self.transport.is_closing(): |
| 325 | return |
| 326 | |
| 327 | # Set a short Keep-Alive timeout. |
| 328 | self._unset_keepalive_if_required() |
| 329 | |
| 330 | self.timeout_keep_alive_task = self.loop.call_later(self.timeout_keep_alive, self.timeout_keep_alive_handler) |
| 331 | |
| 332 | # Unpause data reads if needed. |
| 333 | self.flow.resume_reading() |
| 334 | |
| 335 | # Unblock any pipelined events. |
| 336 | if self.conn.our_state is h11.DONE and self.conn.their_state is h11.DONE: |
| 337 | self.conn.start_next_cycle() |
| 338 | self.handle_events() |
| 339 | |
| 340 | def shutdown(self) -> None: |
| 341 | """ |
nothing calls this directly
no test coverage detected