(self)
| 1015 | return b |
| 1016 | |
| 1017 | def _check_closed(self) -> None: |
| 1018 | if self.closed(): |
| 1019 | raise StreamClosedError(real_error=self.error) |
| 1020 | |
| 1021 | def _maybe_add_error_listener(self) -> None: |
| 1022 | # This method is part of an optimization: to detect a connection that |
no test coverage detected