def test_blocking_get(self):
    q = asyncio.Queue(loop=self.loop)
    q.put_nowait(1)

    @asyncio.coroutine
    def queue_get():
        return (yield from q.get())
    res = self.loop.run_until_complete(queue_get())
    self.assertEqual(1, res)
def test_blocking_get(self):
    q = asyncio.Queue(loop=self.loop)
    q.put_nowait(1)

    @asyncio.coroutine
    def queue_get():
        return (yield from q.get())
    res = self.loop.run_until_complete(queue_get())
    self.assertEqual(1, res)