(self, future: "Optional[Future[None]]")
| 569 | return False |
| 570 | |
| 571 | def _finish_request(self, future: "Optional[Future[None]]") -> None: |
| 572 | self._clear_callbacks() |
| 573 | if not self.is_client and self._disconnect_on_finish: |
| 574 | self.close() |
| 575 | return |
| 576 | # Turn Nagle's algorithm back on, leaving the stream in its |
| 577 | # default state for the next request. |
| 578 | self.stream.set_nodelay(False) |
| 579 | if not self._finish_future.done(): |
| 580 | future_set_result_unless_cancelled(self._finish_future, None) |
| 581 | |
| 582 | def _parse_headers(self, data: bytes) -> Tuple[str, httputil.HTTPHeaders]: |
| 583 | # The lstrip removes newlines that some implementations sometimes |
no test coverage detected