def test_join_empty_queue(self):
    q = self.q_class(loop=self.loop)

    @asyncio.coroutine
    def join():
        (yield from q.join())
        (yield from q.join())
    self.loop.run_until_complete(join())
def test_join_empty_queue(self):
    q = self.q_class(loop=self.loop)

    @asyncio.coroutine
    def join():
        (yield from q.join())
        (yield from q.join())
    self.loop.run_until_complete(join())