(self, n: int)
| 1130 | self.handler.on_ws_connection_close(self.close_code, self.close_reason) |
| 1131 | |
| 1132 | async def _read_bytes(self, n: int) -> bytes: |
| 1133 | data = await self.stream.read_bytes(n) |
| 1134 | self._wire_bytes_in += n |
| 1135 | return data |
| 1136 | |
| 1137 | async def _receive_frame(self) -> None: |
| 1138 | # Read the frame header. |
no test coverage detected