@pytest.mark.asyncio
async def test_close_when_connected(self, redis):
    (await redis._raw('set', Keys.KEY, 1))
    (await redis._close())
    assert (redis._pool.clear.call_count == 1)
@pytest.mark.asyncio
async def test_close_when_connected(self, redis):
    (await redis._raw('set', Keys.KEY, 1))
    (await redis._close())
    assert (redis._pool.clear.call_count == 1)