def test_nonblocking_put_exception(self):
    q = asyncio.Queue(maxsize=1, loop=self.loop)
    q.put_nowait(1)
    self.assertRaises(asyncio.QueueFull, q.put_nowait, 2)
def test_nonblocking_put_exception(self):
    q = asyncio.Queue(maxsize=1, loop=self.loop)
    q.put_nowait(1)
    self.assertRaises(asyncio.QueueFull, q.put_nowait, 2)