(self, msg: str)
| 322 | yield from self.close_connection(message) |
| 323 | |
| 324 | def close_connection(self, msg: str) -> CommandGenerator[None]: |
| 325 | yield CloseConnection(self.conn) |
| 326 | for stream_id in self.streams: |
| 327 | yield ReceiveHttp( |
| 328 | self.ReceiveProtocolError( |
| 329 | stream_id, msg, self.ReceiveProtocolError.code |
| 330 | ) |
| 331 | ) |
| 332 | self.streams.clear() |
| 333 | self._handle_event = self.done # type: ignore |
| 334 | |
| 335 | @expect(DataReceived, HttpEvent, ConnectionClosed, Wakeup) |
| 336 | def done(self, _) -> CommandGenerator[None]: |
no test coverage detected