def test_nonblocking_get(self):
    q = asyncio.Queue(loop=self.loop)
    q.put_nowait(1)
    self.assertEqual(1, q.get_nowait())
def test_nonblocking_get(self):
    q = asyncio.Queue(loop=self.loop)
    q.put_nowait(1)
    self.assertEqual(1, q.get_nowait())