(self)
| 244 | self.assertTrue(finished) |
| 245 | |
| 246 | def test_nonblocking_put(self): |
| 247 | q = asyncio.Queue() |
| 248 | q.put_nowait(1) |
| 249 | self.assertEqual(1, q.get_nowait()) |
| 250 | |
| 251 | async def test_get_cancel_drop_one_pending_reader(self): |
| 252 | q = asyncio.Queue() |
nothing calls this directly
no test coverage detected