conftest.py 文件源码

def create_redis_pool(_closable, loop):
    """Wrapper around aioredis.create_redis_pool."""

    @asyncio.coroutine
    def f(*args, **kw):
        kw.setdefault('loop', loop)
        redis = yield from aioredis.create_redis_pool(*args, **kw)
        _closable(redis)
        return redis
    return f