(self)
| 358 | RuntimeError, self.loop.run_until_complete, ws.receive()) |
| 359 | |
| 360 | def test_close_exc(self): |
| 361 | req = self.make_request('GET', '/') |
| 362 | reader = self.reader.set_parser.return_value = mock.Mock() |
| 363 | |
| 364 | ws = WebSocketResponse() |
| 365 | self.loop.run_until_complete(ws.prepare(req)) |
| 366 | |
| 367 | exc = ValueError() |
| 368 | reader.read.return_value = asyncio.Future(loop=self.loop) |
| 369 | reader.read.return_value.set_exception(exc) |
| 370 | |
| 371 | self.loop.run_until_complete(ws.close()) |
| 372 | self.assertTrue(ws.closed) |
| 373 | self.assertIs(ws.exception(), exc) |
| 374 | |
| 375 | ws._closed = False |
| 376 | reader.read.return_value = asyncio.Future(loop=self.loop) |
| 377 | reader.read.return_value.set_exception(asyncio.CancelledError()) |
| 378 | self.assertRaises(asyncio.CancelledError, |
| 379 | self.loop.run_until_complete, ws.close()) |
| 380 | self.assertEqual(ws.close_code, 1006) |
| 381 | |
| 382 | def test_close_exc2(self): |
| 383 | req = self.make_request('GET', '/') |
nothing calls this directly
no test coverage detected