def test_nonblocking_get_exception(self):
    q = asyncio.Queue(loop=self.loop)
    self.assertRaises(asyncio.QueueEmpty, q.get_nowait)
def test_nonblocking_get_exception(self):
    q = asyncio.Queue(loop=self.loop)
    self.assertRaises(asyncio.QueueEmpty, q.get_nowait)