def test_blocking_put(self):
    q = asyncio.Queue(loop=self.loop)

    @asyncio.coroutine
    def queue_put():
        (yield from q.put(1))
    self.loop.run_until_complete(queue_put())
def test_blocking_put(self):
    q = asyncio.Queue(loop=self.loop)

    @asyncio.coroutine
    def queue_put():
        (yield from q.put(1))
    self.loop.run_until_complete(queue_put())