redis.py

    class _RedisPool(aioredis.RedisPool):
        @asyncio.coroutine
        def acquire(self):
            # XXX
            with (yield from self._cond):
                while True:
                    yield from self._fill_free(override_min=True)
                    if self.freesize:
                        conn = self._pool.popleft()
                        if conn.closed:
                            continue
                        assert conn not in self._used, (conn, self._used)
                        self._used.add(conn)
                        return conn
                    else:
                        yield from self._cond.wait()