(self, n: int)
| 1109 | self.handler.on_ws_connection_close(self.close_code, self.close_reason) |
| 1110 | |
| 1111 | async def _read_bytes(self, n: int) -> bytes: |
| 1112 | data = await self.stream.read_bytes(n) |
| 1113 | self._wire_bytes_in += n |
| 1114 | return data |
| 1115 | |
| 1116 | async def _receive_frame(self) -> None: |
| 1117 | # Read the frame header. |
no test coverage detected