(self)
| 126 | self.assertEqual(1, await q.get()) |
| 127 | |
| 128 | async def test_get_with_putters(self): |
| 129 | loop = asyncio.get_running_loop() |
| 130 | |
| 131 | q = asyncio.Queue(1) |
| 132 | await q.put(1) |
| 133 | |
| 134 | waiter = loop.create_future() |
| 135 | q._putters.append(waiter) |
| 136 | |
| 137 | self.assertEqual(1, await q.get()) |
| 138 | self.assertTrue(waiter.done()) |
| 139 | self.assertIsNone(waiter.result()) |
| 140 | |
| 141 | async def test_blocking_get_wait(self): |
| 142 | loop = asyncio.get_running_loop() |
nothing calls this directly
no test coverage detected