(self)
| 322 | self.assertRaises(asyncio.QueueFull, q.put_nowait, 2) |
| 323 | |
| 324 | async def test_float_maxsize(self): |
| 325 | q = asyncio.Queue(maxsize=1.3, ) |
| 326 | q.put_nowait(1) |
| 327 | q.put_nowait(2) |
| 328 | self.assertTrue(q.full()) |
| 329 | self.assertRaises(asyncio.QueueFull, q.put_nowait, 3) |
| 330 | |
| 331 | q = asyncio.Queue(maxsize=1.3, ) |
| 332 | |
| 333 | await q.put(1) |
| 334 | await q.put(2) |
| 335 | self.assertTrue(q.full()) |
| 336 | |
| 337 | async def test_put_cancelled(self): |
| 338 | q = asyncio.Queue() |
nothing calls this directly
no test coverage detected