def test_put_with_waiting_getters(self):
    q = asyncio.Queue(loop=self.loop)
    t = asyncio.Task(q.get(), loop=self.loop)
    test_utils.run_briefly(self.loop)
    self.loop.run_until_complete(q.put('a'))
    self.assertEqual(self.loop.run_until_complete(t), 'a')
def test_put_with_waiting_getters(self):
    q = asyncio.Queue(loop=self.loop)
    t = asyncio.Task(q.get(), loop=self.loop)
    test_utils.run_briefly(self.loop)
    self.loop.run_until_complete(q.put('a'))
    self.assertEqual(self.loop.run_until_complete(t), 'a')