def test_empty(self):
    q = asyncio.Queue(loop=self.loop)
    self.assertTrue(q.empty())
    q.put_nowait(1)
    self.assertFalse(q.empty())
    self.assertEqual(1, q.get_nowait())
    self.assertTrue(q.empty())
def test_empty(self):
    q = asyncio.Queue(loop=self.loop)
    self.assertTrue(q.empty())
    q.put_nowait(1)
    self.assertFalse(q.empty())
    self.assertEqual(1, q.get_nowait())
    self.assertTrue(q.empty())